Skip to main content
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]
Re: [paho-dev] About java.io.EOFException
Lan, thanks a lot for your reply. 

ActieMQ report exception is: 2014-03-19 08:23:21,658 | WARN  | Transport Connection to: tcp://115.174.60.222:23369 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///115.174.60.222:23369@1883
2014-03-19 08:25:08,323 | WARN  | Transport Connection to: tcp://115.174.60.222:23388 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///115.174.60.222:23388@1883

And when this exception raised, too many duplicated messages are sent.

2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/161
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/161
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/161
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/162
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/162
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/162
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/163
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/163
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/163
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/164
2014-03-19 08:22:54 [ MqttServer:publish ] - [ DEBUG ] DSC try to publish data PublishData [topic=100001000100000001/DSC/C/SET, message=[{"hid":"101001000100000001","fg":1,"f":4,"v":"0"}], qos=1]
2014-03-19 08:22:54 [ MqttThread:messageArrived ] - [ DEBUG ] USER_0 get message with topic=000000000000100001/USER/S/SET; payload=[{"sid":"000000000000100022","status":0}]
2014-03-19 08:22:54 [ UserServerThread:processSET ] - [ INFO ] USER_0 SET[UserSetV [sid=000000000000100022, status=0]]:/2014/03/19/08/22/54/164

Thanks again!

Jonathan



2014-03-14 0:21 GMT+08:00 Ian Craggs <icraggs@xxxxxxxxxxxxxxxxxxxxxxx>:
It looks like the server has disconnected the application.  I would look at the ActiveMQ log first to see if it can explain why.

Ian


On 03/13/2014 02:59 AM, Jonathan Zhou wrote:
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


_______________________________________________
paho-dev mailing list
paho-dev@xxxxxxxxxxx
https://dev.eclipse.org/mailman/listinfo/paho-dev


-- 
Ian Craggs                          
icraggs@xxxxxxxxxx                 IBM United Kingdom
Committer on Paho, Mosquitto

_______________________________________________
paho-dev mailing list
paho-dev@xxxxxxxxxxx
https://dev.eclipse.org/mailman/listinfo/paho-dev


Back to the top