ActiveMQ 代理错误消息 : Async error occurred: java. lang.NullPointerException

Question

我在 activemq.log 中收到如下消息，

Async error occurred: java.lang.IllegalStateException: Cannot add a producer to a connection that had not been registered: ID:BlackApple-2.local-50258-1366686550079-0:1 | org.apache.activemq.broker.TransportConnection.Service | ActiveMQ Transport: ssl:///<ip>:50264
java.lang.IllegalStateException: Cannot add a producer to a connection that had not been registered: ID:BlackApple-2.local-50258-1366686550079-0:1

Async error occurred: java.lang.NullPointerException | rg.apache.activemq.broker.TransportConnection.Service | ActiveMQ Transport: ssl:///<ip>:50264
java.lang.NullPointerException

Async error occurred: java.lang.IllegalStateException: Cannot remove a consumer from a connection that had not been registered: ID:BlackApple-2.local-50258-1366686550079-0:1 | org.apache.activemq.broker.TransportConnection.Service | ActiveMQ Transport: ssl:///<ip>:50264
java.lang.IllegalStateException: Cannot remove a consumer from a connection that had not been registered: ID:BlackApple-2.local-50258-1366686550079-0:1

我的 broker 版本是 5.6，我只有一个 broker(没有集群问题)。发生了什么以及如何解决这些问题？或者忽略这些错误消息是否安全？

网上很少有资料...

谢谢。

编辑:在使用 log4j 2 格式 %ex{full} 获取完整堆栈跟踪后，我得到了更多详细信息:

org.apache.activemq.transport.TransportDisposedIOException: peer (vm://broker-amq-2-1-tbk64#3) stopped.
    at org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:230)
    at org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
    at org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65)
    at org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)
    at org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:1189)
    at org.apache.activemq.broker.TransportConnection$4.run(TransportConnection.java:1155)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:750)

Answer 1

似乎代码中的某处在代理已经停止时停止了代理。还没有找到它，但看起来还不错。