Hi All Expert,
Now we are using PAHO Java client to connect ActiveMQ, it
reports java.io.EOFException some times. Anyone have idea
about this? thanks!
the stack info as bellow:
[ ERROR ] USER_0 publish content error:PublishData
[topic=000000000000100001/LOGINSUCCESS, message=, qos=1]
Client is not connected (32104)
at
org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:27)
at
org.eclipse.paho.client.mqttv3.internal.ClientComms.sendNoWait(ClientComms.java:132)
at
org.eclipse.paho.client.mqttv3.MqttAsyncClient.publish(MqttAsyncClient.java:785)
at
org.eclipse.paho.client.mqttv3.MqttClient.publish(MqttClient.java:315)
at
org.eclipse.paho.client.mqttv3.MqttClient.publish(MqttClient.java:307)
at
com.ipower365.boss.mqtt.thread.MqttThread.run(MqttThread.java:240)
2014-03-12 23:19:20 [ MqttThread:run ] - [ INFO ] USER_0
wait for 0s due to publish error
2014-03-12 23:19:20 [ MqttThread:run ] - [ DEBUG ] USER_0
try to publish PublishData
[topic=000000000000100001/LOGINSUCCESS, message=, qos=1] to
tcp://
115.28.152.227:1883
2014-03-12 23:19:20 [ MqttThread:run ] - [ ERROR ] USER_0
publish content error:PublishData
[topic=000000000000100001/LOGINSUCCESS, message=, qos=1]
Client is not connected (32104)
at
org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:27)
at
org.eclipse.paho.client.mqttv3.internal.ClientComms.sendNoWait(ClientComms.java:132)
at
org.eclipse.paho.client.mqttv3.MqttAsyncClient.publish(MqttAsyncClient.java:785)
at
org.eclipse.paho.client.mqttv3.MqttClient.publish(MqttClient.java:315)
at
org.eclipse.paho.client.mqttv3.MqttClient.publish(MqttClient.java:307)
at
com.ipower365.boss.mqtt.thread.MqttThread.run(MqttThread.java:240)
2014-03-12 23:19:20 [ MqttThread:run ] - [ INFO ] USER_0
wait for 1s due to publish error
2014-03-12 23:19:20 [ MqttThread:connectionLost ] - [ ERROR
] USER_0 lost the connection from tcp://
115.28.152.227:1883 try to reconnecting
...
Connection lost (32109) - java.io.EOFException
at
org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:138)
at java.lang.Thread.run(Thread.java:662)
Caused by: java.io.EOFException
at
java.io.DataInputStream.readByte(DataInputStream.java:250)
at
org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream.readMqttWireMessage(MqttInputStream.java:56)
at
org.eclipse.paho.client.mqttv3.internal.CommsReceiver.run(CommsReceiver.java:100)
... 1 more
2014-03-12 23:19:20 [ MqttThread:connect ] - [ INFO ]
USER_0 try to connect to server tcp://
115.28.152.2
Thanks & Regards,
Jonathan