AtherEnergy / rumqtt

Pure rust mqtt cilent
The Unlicense
202 stars 71 forks source link

Reconnection error log shows ping error instead of connection error #126

Closed tekjar closed 5 years ago

tekjar commented 5 years ago

cargo run --example=keepalive"

 ERROR rumqtt::client::mqttstate  > Error awaiting for last ping response
 DEBUG rumqtt::client::mqttstate  > keep alive = 10, 
            last incoming pkt before 29 secs, 
            last outgoing pkt before 20 secs
 ERROR rumqtt::client::mqttstate  > Error awaiting for last ping response
 DEBUG rumqtt::client::mqttstate  > keep alive = 10, 
            last incoming pkt before 37 secs, 
            last outgoing pkt before 27 secs
 ERROR rumqtt::client::mqttstate  > Error awaiting for last ping response
 DEBUG rumqtt::client::mqttstate  > keep alive = 10, 
            last incoming pkt before 37 secs, 
            last outgoing pkt before 27 secs
 ERROR rumqtt::client::mqttstate  > Error awaiting for last ping response
 ERROR rumqtt::client::connection > This shouldn't have happened: Error = Io(Os { code: 32, kind: BrokenPipe, message: "Broken pipe" })
 DEBUG rumqtt::client::connection > Mqtt connect response = Some(Connack(Connack { session_present: false, code: Accepted }))
 DEBUG rumqtt::client::connection > Mqtt connection successful!!
tekjar commented 5 years ago

Fixed in #127