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