为Camel JMS生产者设置ConnectionFactory：Camel JMS Vs Camel sjms

Question

您好，我的基本要求是有一个可以发送消息的路由，并将其放在JMS队列中。camel上下文在JavaEE 6容器中运行，即JBoss AS 7.1.1，因此它附带了HornetQ for JMS；我通过引导单例启动上下文，但我不使用camel cdi。到目前为止，我一直在使用camel-jms组件，但现在我希望尽可能迁移到camel-sjms，因为springless。

我的问题是：在这个JavaEE场景中为camel-sjms配置ConnectionFactory的正确方法是什么？

使用camel-jms，我可以将其放在endpointURL中，非常简单。至（“jms:myQueue？connectionFactory=#connectionFactory”）。相反，对于camel-sjms，在我看来，我需要自己创建一个SJMSComponent实例，设置connectionFactory，并在启动之前在camel上下文中设置该实例。

我下面有camel-jms Vs camel-sjms案例的代码，我想知道我是否正确“迁移”了ConnectionFactory的设置。谢谢。

@Singleton
@Startup
public class CamelBootstrap {
    private CamelContext camelContext;
    private ProducerTemplate producerTemplate;

    public CamelContext getCamelContext() {
        return camelContext;
    }

    public ProducerTemplate getProducerTemplate() {
        return producerTemplate;
    }

    @PostConstruct
    public void init() throws Exception {
        camelContext = new DefaultCamelContext();
        camelContext.addRoutes(new MyCamelRoutes());
        camelContext.start();
        producerTemplate = camelContext.createProducerTemplate();
    }
}

没什么特别的，在MyCamelRoutes中，我可以使用以下方式进行路由配置：

.to("jms:myQueue?connectionFactory=#ConnectionFactory")

@Singleton
@Startup
public class CamelBootstrap {

    @Resource(mappedName="java:/ConnectionFactory")
    private ConnectionFactory connectionFactory;

    private CamelContext camelContext;
    private ProducerTemplate producerTemplate;

    public CamelContext getCamelContext() {
        return camelContext;
    }

    public ProducerTemplate getProducerTemplate() {
        return producerTemplate;
    }

    @PostConstruct
    public void init() throws Exception {
        camelContext = new DefaultCamelContext();

        SjmsComponent sjms = new SjmsComponent();
        sjms.setConnectionFactory(connectionFactory);
        camelContext.addComponent("sjms", sjms);

        camelContext.addRoutes(new MyCamelRoutes());
        camelContext.start();
        producerTemplate = camelContext.createProducerTemplate();
    }
}

请注意连接工厂的@Resources，这是作为对SjmsComponent实例的引用传递的，该实例被传递给camelContext。然后在MyCamelRoutes中，我可以使用sjms，同时使用：

.to("sjms:myQueue")

Answer 1

如果不缓存/池化JMS资源，可能会出现性能问题。缓存通常是通过在某些缓存ConnectionFactory库中包装ConnectionFactory来配置的，或者通过将控制权移交给应用程序服务器来配置的。

Camel SJMS包括内置池。但是，如果您有容器管理的资源来处理JMS连接，您可能应该考虑使用它。SJMS有一些工具来处理它，ConncetionResources而不是ConnectionFactory。