利用JFinal-Ext使用ActiveMQ经常出现以下警告

Question

利用JFinal-Ext使用ActiveMQ经常出现以下警告，哪位遇到过类似的问题么？

[WARN]-[Thread: ActiveMQ Transport: tcp:///192.168.10.181:61616@2123]-[org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure()]: Transport (tcp:///192.168.10.181:61616@2123) failed, reason:  , attempting to automatically reconnect

java.io.EOFException
    at java.io.DataInputStream.readInt(Unknown Source)
    at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:275)
    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)
    at java.lang.Thread.run(Unknown Source)

Answer 1

引用来自“绝望的八皮”的评论

可能是comsumer没有正常关闭．这个插件历史比较久，我看下代码优化一版本，下周一会发布正式３.1.3版本，如果有兴趣可以自己改一下源代码帮忙测试一下．我现在没有mq的环境．

在jmsplugin的stop方法．

public boolean stop() {
        listeners.clear();
        return true;
    }

return前遍历listerners调用closeConnection方法，但是这这个方法并不在MessageListener接口里面而在它的两个实现类topiclistener和queueListener，所以需要遍历出来判断下类型强制转化后调用．

有兴趣折腾一下帮忙test一把～

Answer 2

牛

Answer 3

好

Answer 4

不错

Answer 5

测试中

Answer 6

可能是comsumer没有正常关闭．这个插件历史比较久，我看下代码优化一版本，下周一会发布正式３.1.3版本，如果有兴趣可以自己改一下源代码帮忙测试一下．我现在没有mq的环境．

在jmsplugin的stop方法．

public boolean stop() {
        listeners.clear();
        return true;
    }

return前遍历listerners调用closeConnection方法，但是这这个方法并不在MessageListener接口里面而在它的两个实现类topiclistener和queueListener，所以需要遍历出来判断下类型强制转化后调用．

有兴趣折腾一下帮忙test一把～