Spring JMS侦听器未连接到ActiveMQ

Question

   <!-- ActiveMQ Configuration -->
    <jms:annotation-driven/>

    <!-- JMS ConnectionFactory to use, configuring the embedded broker using XML -->
    <bean id="jmsConnectionFactory" class="org.apache.activemq.spring.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://xxxx.xxxx.net:8161" />
    </bean>


    <bean id="jmsListenerContainerFactory"
          class="org.springframework.jms.config.DefaultJmsListenerContainerFactory">
        <property name="connectionFactory" ref="jmsConnectionFactory"/>
        <property name="concurrency" value="3-10"/>
    </bean>

@Component
public class MessageListenerExample {

    @JmsListener(destination = "TestQueue")
    public void doSomething(String message) {
        System.out.println("OnMessage Received  :" + message);

    }
}

现在当我启动基于spring的应用程序时。我在调试器中看到，我的侦听器方法注册了，但是Spring不连接到ActiveMQ队列，我可以通过查看ActiveMQ web控制台轻松地看到这一点。此外，我没有看到任何来自spring的日志输出，而JMS的东西是这样做的。

我错过什么了吗？从这里走下去最好的路是什么？当然，我也测试了从ActiveMQ的web控制台中发送消息，但是如果没有客户端连接，就没有交付的希望。谢谢你的意见。

更新：我找到一个StackTrace...

[WARN 14:02:58] DefaultMessageListenerContainer.handleListenerSetupFailure(860) | Setup of JMS message listener invoker failed for destination 'TestQueue' - trying to recover. Cause: The JMS connection has failed: Unknown data type: 47
org.apache.activemq.ConnectionFailedException: The JMS connection has failed: Unknown data type: 47
    at org.apache.activemq.ActiveMQConnection.checkClosedOrFailed(ActiveMQConnection.java:1480)
    at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:324)
    at org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:192)
    at org.springframework.jms.listener.DefaultMessageListenerContainer.access$1400(DefaultMessageListenerContainer.java:122)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1162)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1141)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1134)
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:1031)
    at java.lang.Thread.run(Thread.java:745)
Caused by: java.io.IOException: Unknown data type: 47
    at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:365)
    at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:285)
    at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)
    at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)
    at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
    ... 1 more

Answer 1

因为我看错了日志，我没有看到明显的。我张贴这是因为这是很多人可能会绊倒。

我在spring配置中定义了错误的端口。我错误地使用了web控制台端口，但我当然希望使用位于端口61616上的TCP传输。

这是Bruce Snider在web的某个地方提到的，作为对同样问题的答复。