从 Camel 连接到 JBoss EAP6 上的队列

Question

我在 standalone.xml 文件中的 JBoss EAP6 上设置了一个 HornetQ JMS 队列。

<hornetq-server>
[...]
    <jms-connection-factories>
        <connection-factory name="RemoteConnectionFactory">
            <connectors>
                <connector-ref connector-name="netty"/>
            </connectors>
            <entries>
                <entry name="java:jboss/exported/jms/RemoteConnectionFactory"/>
            </entries>
        </connection-factory>
    </jms-connection-factories>

    <jms-destinations>
        <jms-queue name="WorkflowExecution">
            <entry name="/queue/MyQueue"/>
            <entry name="java:jboss/exported/queue/MyQueue"/>
        </jms-queue>
    </jms-destinations>
</hornetq-server>

队列工作正常，我可以使用 Hermes JMS 等工具在其上发送消息。

我正在开发 Fuse 4.4 中的独立客户端应用程序运行，它必须通过 Camel 路由向队列发送消息，但我不知道如何在其中设置连接器配置。

这是我在camel-context.xml文件中尝试设置的：

<bean id="jmsinjection" class="org.apache.camel.component.jms.JmsComponent">
  <property name="connectionFactory">
    <bean class="org.springframework.jndi.JndiObjectFactoryBean">
      <property name="jndiName" value="jms/RemoteConnectionFactory" />
      <property name="jndiEnvironment">
        <props>
          <prop key="java.naming.provider.url">remote://myEAPurl:port</prop>
          <prop key="java.naming.factory.initial">org.jboss.naming.remote.client.InitialContextFactory</prop>
        </props>
      </property>
    </bean>
  </property>
</bean>

我得到的异常是：

Error creating bean with name 'jmsinjection' defined in URL [bundle://79.37:0/META-INF/spring/camel-context.xml]: Initialization of bean failed; nested exception is org.springframework.beans.ConversionNotSupportedException: Failed to convert property value of type 'org.hornetq.jms.client.HornetQJMSConnectionFactory' to required type 'javax.jms.ConnectionFactory' for property 'connectionFactory'; nested exception is java.lang.IllegalStateException: Cannot convert value of type [org.hornetq.jms.client.HornetQJMSConnectionFactory] to required type [javax.jms.ConnectionFactory] for property 'connectionFactory': no matching editors or conversion strategy found

根据 javadoc，HornetQJMSConnectionFactory 实现了扩展 javax.jms.ConnectionFactory 的 javax.jms.QueueConnectionFactory，所以我不明白为什么会出现此异常。

我花了几个小时抓取 JBoss 论坛和文档，但找不到让它工作的方法。

我的骆驼配置有什么问题？如何解决？

Answer 1

问题是由于 OSGi class-loader。

Fuse ESB 已经在 class 路径中加载了 javax.jms.ConnectionFactory 版本。

添加 jboss-client.jar 会将 HornetQJMSConnectionFactory 添加到 class 路径，但也会添加另一个版本的 ConnectionFactory.

解决方案是将以下所有依赖项添加到包中，并删除 this page 中指示的 jboss-client.jar：

hornetq-core
hornetq-jms
jboss-ejb-client
jboss-logging
jboss-logmanager
jboss-marshalling
jboss-marshalling-river
jboss-remote-naming
jboss-remoting
jboss-sasl
netty
remoting-jmx
xnio-api
xnio-nio

您可以直接在 JBoss EAP 实例存储库中找到所有具有正确版本的依赖项。名字可能有点不同。

从 Camel 连接到 JBoss EAP6 上的队列

Connect to a queue on JBoss EAP6 from Camel

java

jboss

jms

apache-camel

jboss6.x