ActiveMQ嵌入式桥到Camel JMS桥

Question

我有一个旧的应用程序，它用ActiveMQ 5.8.0处理JMS消息，还有一些JNDI远程主题连接到这个ActiveMQ。

我有一个这样的连接器：

<bean class="org.apache.activemq.network.jms.JmsConnector">
    <property name="outboundTopicConnectionFactory" ref="jmsConnectionFactoryTo" />
    <property name="outboundClientId" value="${remote.clientId}" />
    <property name="jndiOutboundTemplate" ref="jndiTemplateTo" />
    <property name="preferJndiDestinationLookup" value="true" />
    <property name="inboundTopicBridges">
        <list>
            <bean class="org.apache.activemq.network.jms.InboundTopicBridge">
                <property name="inboundTopicName" value="${remote.topic.to}"/> 
                <property name="localTopicName" value="${local.topic.to}"/>
                <property name="consumerName" value="${remote.consumer.name}"/>
                <property name="selector" value="${remote.selector}"/>
            </bean>
        </list>
    </property>
</bean>

它工作得很好，但是现在，由于一些技术原因（严格的JMS 1.1），我需要使用“ConnectionFactory”而不是“TopicConnectionFactory”。在实际配置中，我被卡住了，因为ActiveMQ似乎使用了“TopicConnectionFactory”而不是“ConnectionFactory”，而我的新类“MyConnectionFactoryImpl”现在实现了“ConnectionFactory”：

nested exception is org.springframework.beans.ConversionNotSupportedException: 
Failed to convert property value of type 'com.webmethods.jms.impl.MyConnectionFactoryImpl' 
to required type 'javax.jms.TopicConnectionFactory' 
for property 'outboundTopicConnectionFactory'; 
nested exception is java.lang.IllegalStateException: 
Cannot convert value of type [com.webmethods.jms.impl.MyConnectionFactoryImpl] 
to required type [javax.jms.TopicConnectionFactory] for property 'outboundTopicConnectionFactory': 
no matching editors or conversion strategy found

在"org.apache.activemq.network.jms.JmsConnector"类中，它到处使用"TopicConnectionFactory"，这在JMS 1.1中不再被推荐。

编辑：根据@Justin Bertram，我需要使用Camel而不是ActiveMQ嵌入式桥接器。但我找不到任何XML配置的例子，可以用来替换我的实际的双bean JMSConnector。保存XML配置文件的简单方法是什么？

Answer 1

我认为让代码返回TopicConnectionFactory将是最简单的解决方案。甚至JMS 2.0规范也提供了TopicConnectionFactory。无论您使用的是哪个版本的ActiveMQ，您都可以选择在代码中使用TopicConnectionFactory，并将其提供给网桥。

请注意骆驼路线：

   <camelContext xmlns="http://camel.apache.org/schema/spring">
      <route>
         <from uri="mqseries:Foo.Bar"/>
         <to uri="activemq:Cheese"/>
      </route>
   </camelContext>

没有错误处理。例如，如果'to'终结点已关闭，则此路由将从'from'终结点读取消息，并将消息抛到地板上。此外，如果'to'组件没有配置为使用缓存/池连接工厂，那么将为发送的每条消息创建一个新的JMS连接。这具有较差的性能，并可能导致许多套接字处于TIME_WAIT状态。底线——小心琐碎的骆驼路线。

Answer 2

正如JMS到JMS桥的留档（即org.apache.activemq.network.jms.JmsConnector）所述：

ActiveMQ为实现JMS 1.0.2及以上规范的其他JMS提供程序提供桥接功能。

换句话说，JMS到JMS桥的整个目标是使用JMS 1.0.2接口。将其更改为仅使用JMS 1.1将无法达到目的。

该文档还指出，您应该使用Camel，而不是JMS到JMS桥：

警告，先试试骆驼！

请注意，我们建议您考虑使用Apache Camel将ActiveMQ连接到任何消息代理（或任何其他技术、协议或中间件），因为这样做更容易：

• 保持灵活性；将不同的队列/主题映射到另一个提供程序上的一个或多个队列或主题非常容易
• 执行基于内容的路由、过滤和其他企业集成模式
• 允许您使用任何技术、协议或中间件，而不仅仅是JMS提供商

因此，我建议您使用Camel而不是org。阿帕奇。activemq。网络jms。JMS连接器。