jacodutoit
diff --git a/‎src/MqttClient.cpp
Copy file name to clipboardExpand all lines: src/MqttClient.cpp
+4Lines changed: 4 additions & 0 deletions b/‎src/MqttClient.cpp
Copy file name to clipboardExpand all lines: src/MqttClient.cpp
+4Lines changed: 4 additions & 0 deletions
@@ -547,6 +547,10 @@ void MqttClient::poll()
 
             if (_onMessage) {
               _onMessage(_rxLength);
+
+              if (_rxLength == 0) {
+                _rxState = MQTT_CLIENT_RX_STATE_READ_TYPE;
+              }
             }
           }
         }
Original file line number	Diff line number	Diff line change
`@@ -547,6 +547,10 @@ void MqttClient::poll()`
`547`	`547`
`548`	`548`	`if (_onMessage) {`
`549`	`549`	`_onMessage(_rxLength);`
	`550`	`+`
	`551`	`+ if (_rxLength == 0) {`
	`552`	`+ _rxState = MQTT_CLIENT_RX_STATE_READ_TYPE;`
	`553`	`+ }`
`550`	`554`	`}`
`551`	`555`	`}`
`552`	`556`	`}`