activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From oliverd <oliver.deck...@hotmail.com>
Subject Re: MQTT NIO transport hangup
Date Thu, 03 Jul 2014 08:39:52 GMT
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.

Mime
View raw message