Spring侦听器未拾取JMS消息

Question

我有一个Spring应用程序在独立的JBoss EAP 6.2中运行（带有嵌入式HornetQ提供程序）。

消息被成功地放在队列中（我可以在jboss eap-6.2\独立\data\MessagingJournal\hornetq-data-1.hq中看到它们，因为队列是持久的），但不会被侦听器拾取（侦听器中的断点不会被命中）。我怀疑配置中缺少或错误的东西，但看不出是什么。JBoss启动时没有任何验证错误。

首先，Spring的应用摘录ontext.xml：

连接工厂和队列的JNDI名称与JBossstandalone-full.xml中的名称相匹配

<jee:jndi-lookup id="jmsConnectionFactory" jndi-name="java:/JmsXA" resource-ref="false" proxy-interface="javax.jms.ConnectionFactory"/> 

<jee:jndi-lookup id="myQueue" jndi-name="java:jboss/exported/jms/queue/myQueue"/> 

<bean id="myHandler" class="com.example.MyHandler" />

<jms:listener-container destination-type="queue" acknowledge="auto" connection-factory="jmsConnectionFactory">
    <jms:listener destination="java:jboss/exported/jms/queue/myQueue" ref="myHandler" method="processMessage" />
</jms:listener-container>

消息处理程序被声明为Spring组件，并且类和方法名与上面声明的相匹配：

@Component
public class MyHandler {

public void processMessage(MyMessage delaySendTransfer) {
    //...
}

Answer 1

默认情况下，Spring对侦听器容器使用DynamicDestinationResolver，因此它希望在侦听器的destination属性中接收bean引用。由于您使用的是JNDI名称，因此应该将目标解析器策略设置为jndiDestinationResolver。

<jms:listener-container destination-resolver="jndiDestinationResolver" destination-type="queue" acknowledge="auto" connection-factory="jmsConnectionFactory">
    <jms:listener destination="java:jboss/exported/jms/queue/myQueue" ref="myHandler" method="processMessage" />
</jms:listener-container>

用bean引用替换目标属性值也可以做到这一点：

<jms:listener-container destination-type="queue" acknowledge="auto" connection-factory="jmsConnectionFactory">
    <jms:listener destination="myQueue" ref="myHandler" method="processMessage" />
</jms:listener-container>