repeated the test with v5.10.0 - same behavior stack trace shows: Name: ActiveMQ NIO Worker 2 State: RUNNABLE Total blocked: 0 Total waited: 1
Stack trace: org.fusesource.hawtbuf.DataByteArrayInputStream.readByte(DataByteArrayInputStream.java:224) org.apache.activemq.transport.mqtt.MQTTCodec.processHeader(MQTTCodec.java:100) org.apache.activemq.transport.mqtt.MQTTCodec.parse(MQTTCodec.java:73) org.apache.activemq.transport.mqtt.MQTTNIOTransport.serviceRead(MQTTNIOTransport.java:105) org.apache.activemq.transport.mqtt.MQTTNIOTransport.access$000(MQTTNIOTransport.java:43) org.apache.activemq.transport.mqtt.MQTTNIOTransport$1.onSelect(MQTTNIOTransport.java:66) org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:94) org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119) java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) java.lang.Thread.run(Thread.java:662) or: Name: ActiveMQ NIO Worker 2 State: RUNNABLE Total blocked: 0 Total waited: 1 Stack trace: org.apache.activemq.transport.mqtt.MQTTCodec.processHeader(MQTTCodec.java:104) org.apache.activemq.transport.mqtt.MQTTCodec.parse(MQTTCodec.java:73) org.apache.activemq.transport.mqtt.MQTTNIOTransport.serviceRead(MQTTNIOTransport.java:105) org.apache.activemq.transport.mqtt.MQTTNIOTransport.access$000(MQTTNIOTransport.java:43) org.apache.activemq.transport.mqtt.MQTTNIOTransport$1.onSelect(MQTTNIOTransport.java:66) org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:94) org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:119) java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) java.lang.Thread.run(Thread.java:662) i.e. it spins thru the while loop in the processHeader method also tried with different mqtt-client versions 1.4, 1.6, 1.8 - no change -- View this message in context: http://activemq.2283324.n4.nabble.com/MQTT-NIO-transport-hangup-tp4682745p4682759.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
