0

我目前正在设置一个运行嵌入式 ActiveMQ 代理的 Tomcat 服务器。我正在使用 Spring 来配置 JMS。我编写了一个测试应用程序来监听主题，当我退出测试应用程序时，ActiveMQ 代理会抛出一个 SocketException。这是一个例外：

2009-06-09 13:12:48,005 DEBUG Transport:229 - Transport failed: java.net.SocketException: Connection reset
java.net.SocketException: Connection reset
        at java.net.SocketInputStream.read(SocketInputStream.java:168)
        at org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:50)
        at org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:58)
        at java.io.DataInputStream.readInt(DataInputStream.java:370)
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:210)
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:202)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
        at java.lang.Thread.run(Thread.java:619)

我的测试应用程序只是加载上下文 xml 文件，每 60 秒循环睡眠一次。 

public static void main(String[] args) {
        long numMillisecondsToSleep = 60000; 
        new ClassPathXmlApplicationContext("client-context.xml");  

        while (true) {
            try {
                logger.info("Sleeping for 60 seconds");
                Thread.sleep(numMillisecondsToSleep);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

我想知道是否有人可能知道我为什么会收到此异常。一般来说，我对 ActiveMQ 和 JMS 非常陌生，因此任何想法都将不胜感激。

4

2 回答 2

0

I think there's a way to shut down an embedded broker nicely via a method call. Posting your config along with your embedding code will help people figure out what's going on.

于 2009-06-09T20:43:03.340 回答
0

我建议查看 Spring 的 JmsTemplates；它将 MQ 的所有复杂性包装到一个漂亮的包中，并确保像这样的小错误不会给您带来数小时的问题。

http://activemq.apache.org/spring-support.html

于 2009-06-13T03:45:33.833 回答