骆驼JMS：如何在连接到主题时配置自定义消息侦听器

Question

我需要定义一个从主题读取消息（包含xml）并将其解组到JavaBean的路由。

早些时候，我使用Spring JmsTemboard来管理这个主题的连接工厂，我的路由看起来像这样（并且工作正常）。消息转换器本质上返回fromMessage（）方法中的TextMessage实例

JaxbDataFormat dataFormat = new JaxbDataFormat();
dataFormat.setContextPath("com.somepath.xml");

from("jms:topic:myTopic?transacted=true&connectionFactory=myJmsConnectionFactory&messageConverter=#myMessageConverter")
 .transacted()
 .unmarshal(dataFormat)
 .routeId("myRouteId")

现在，我使用org.springframework.jms.listener.DefaultMessageListenerContainer来连接到这个持久的主题，而不是JmsTemboard。

（也是因为它支持异步模式）

为此，我编写了自己的消息侦听器，它实现了javax。jms。MessageListener我在onMessage（）中阅读了这条消息。但我不能像使用JmsTemplate时那样从这里返回文本消息。

我不知道如何在路由定义中配置它，使其仍然支持解组？




Answer 1

我尝试了很多东西，解决方案非常简单，没有必要使用org.springframework.jms.listener.DefaultMessageListenerContainer，相反，我们所需要做的就是定义一个连接工厂，在我的情况下是myJmsConnectionFactory实例，定义如下Springxml

<bean id="myJmsConnectionFactory"        class="org.springframework.jndi.JndiObjectFactoryBean">
            <property name="jndiTemplate" ref="myJndiTemplate" />
            <property name="jndiName" value="TopicConnectionFactory" />
            <property name="lookupOnStartup" value="false" />
            <property name="proxyInterfaces" value="javax.jms.ConnectionFactory" />
            <property name="cache" value="true" />
</bean>

这个连接工厂使用一个jndi模板，它有助于远程对象的jndi查找。这被定义为

<bean id="myJndiTemplate" class="org.springframework.jndi.JndiTemplate">
            <property name="environment">
                <bean class="org.springframework.beans.factory.config.PropertiesFactoryBean">
                    <property name="location" value="file:///opt/test/jndi.properties" />
                </bean>
            </property>
</bean>

在路由定义中，我只是使用这个连接工厂来查找远程主题。默认情况下，当您连接到jms主题时，camel会注册一个消息侦听器，您不必指定一个（您可以，但我不需要：）

JaxbDataFormat dataFormat = new JaxbDataFormat();
dataFormat.setContextPath("com.somepath.xml");

from("jms:topic:myTopic?transacted=true&connectionFactory=myJmsConnectionFactory")
 .transacted()
 .unmarshal(dataFormat)
 .routeId("myRouteId")