如何让 Spring 连接我的 JmsComponent

我正在编写一个使用 Akka、Akka-Camel 和 Spring 进行配置的应用程序。应用程序需要充当针对各种应用程序服务器的独立 JMS 客户端，为此，它需要使用 JNDI 设置 JMS 连接工厂。我正在用 jBoss 测试这个。我对jBoss 5和6也有同样的问题（这似乎是客户端Spring问题，与jBoss无关）。

我正在使用以下 xml 配置 Spring beans：

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:camel="http://camel.apache.org/schema/spring"
       xmlns:jee="http://www.springframework.org/schema/jee"
       xsi:schemaLocation="
         http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
         http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
         http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-3.0.xsd
         ">

    <camelContext id="camel" trace="false" xmlns="http://camel.apache.org/schema/spring">
        <jmxAgent id="agent" disabled="true"/>
    </camelContext>

    <jee:jndi-lookup id="jmsConnectionFactory" jndi-name="ConnectionFactory">
        <jee:environment>
            java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
            java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
            java.naming.provider.url=jnp://192.168.0.109:1099
        </jee:environment>
    </jee:jndi-lookup>

    <bean name="jms" class="org.apache.camel.component.jms.JmsComponent">
        <property name="connectionFactory" ref="jmsConnectionFactory" />
    </bean>

</beans>

正如你所看到的，我正在设置：

• 通过 JNDI 初始化的 ConnectionFactory，称为 jmsConnectionFactory
• 一个 JmsComponent，其 connectionFactory 属性设置为前一个 bean

使用此配置，我的应用程序在启动时失败：

java.lang.IllegalArgumentException: connectionFactory must be specified
    at org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:294) ~[camel-core.jar:2.10.4]
    at org.apache.camel.component.jms.JmsConfiguration.createConnectionFactory(JmsConfiguration.java:1053) ~[camel-jms.jar:2.10.4]
    at org.apache.camel.component.jms.JmsConfiguration.getConnectionFactory(JmsConfiguration.java:416) ~[camel-jms.jar:2.10.4]
    at org.apache.camel.component.jms.JmsConfiguration.createListenerConnectionFactory(JmsConfiguration.java:1062) ~[camel-jms.jar:2.10.4]
    at org.apache.camel.component.jms.JmsConfiguration.getListenerConnectionFactory(JmsConfiguration.java:435) ~[camel-jms.jar:2.10.4]
    at org.apache.camel.component.jms.JmsConfiguration.configureMessageListenerContainer(JmsConfiguration.java:889) ~[camel-jms.jar:2.10.4]
    at org.apache.camel.component.jms.JmsConfiguration.createMessageListenerContainer(JmsConfiguration.java:379) ~[camel-jms.jar:2.10.4]

这来自 JmsConfiguration.java 中的这段代码：

protected ConnectionFactory createConnectionFactory() {
    ObjectHelper.notNull(connectionFactory, "connectionFactory");
    return null;
}

因此，Spring bean 初始化似乎无法按照此处的说明关联/连接 bean（从之前粘贴的完整 XML Spring 配置中提取）：

    <bean name="jms" class="org.apache.camel.component.jms.JmsComponent">
        <property name="connectionFactory" ref="jmsConnectionFactory" />
    </bean>

我还尝试创建一个中间 JmsConfiguration bean，并设置 JmsComponent 的配置属性，而不是直接设置 connectionFactory 属性，但我在两种设置中得到相同的结果。

顺便说一句，我可以通过代码连接 bean。我的意思是：

val connFactory = springContext.getBean[javax.jms.ConnectionFactory]("jmsConnectionFactory", classOf[javax.jms.ConnectionFactory])
camelContext.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(connFactory))

工作得很好。所以我知道我正在从 JNDI 获取 ConnectionFactory，只是我无法使用正确的 Spring 配置来将其连接到 XML 中。

我需要这个应用程序具有很强的可配置性，而无需重新编译，因此让 XML 正常工作对我来说是必须的。

如果还不清楚，问题是：如何让 Spring 设置我的 JmsComponent bean，并将其 connectionFactory 设置为 JNDI 获取的工厂？

编辑：使用 Camel 的要点是它应该允许我将该组件交换为另一个不同类型的组件。所以今天我使用 JMS，也许明天我将使用 TCP。这就是为什么能够在 XML 中定义所有内容非常重要。

我相信问题在于 Akka 使用它自己的 CamelContext 而不是 Spring 配置中定义的。在 Akka 的早期版本中，这似乎是可能的设置 Akka 使用的上下文 http://doc.akka.io/docs/akka-modules/1.3.1/modules/camel.html#Standalone_Spring_applications，但在最新版本中似乎不再可能。

我遇到了同样的问题，我在 Java（而不是 Scala）中使用基于注释的配置，并使用以下代码解决了该问题：

@Bean
public ActorSystem getCamelActorSystem(ConnectionFactory factory) {

    ActorSystem system = ActorSystem.create("some-system");

    Camel camel = CamelExtension.get(system);
    CamelContext camelContext = camel.context();
    camelContext.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(factory));

    return system;
}

这会注入在其他地方定义的 ConnectionFactory 依赖项，并使用它将 jms 组件添加到 Akka 使用的camelContext。

另一个解决方案可能是以某种方式扩展 CamelExtension 代码，以允许注入camelContext 依赖项，就像以前可能的那样。然而，我假设他们有充分的理由进行改变，所以我就不管它了。我认为这样他们就可以确保上下文不能更改，因此 Actor 系统始终使用相同的 Camel 上下文，这是基于以下内容：

对于每个 ActorSystem，一个 CamelExtension 只加载一次， 这使得您可以在您的任何时候安全地调用 CamelExtension 代码来获取与其关联的 Apache Camel 对象。有 每个 ActorSystem 对应一个 CamelContext 和一个 ProducerTemplate 使用 CamelExtension。

http://doc.akka.io/docs/akka/current/scala/camel.html#CamelExtension http://doc.akka.io/docs/akka/current/scala/camel.html#CamelExtension