diff --git a/src/mqtt_client.c b/src/mqtt_client.c
index 7de2e1c0..38e28b0a 100644
--- a/src/mqtt_client.c
+++ b/src/mqtt_client.c
@@ -2692,7 +2692,7 @@ int MqttClient_Auth(MqttClient *client, MqttAuth* auth)
 
         auth->stat.write = MQTT_MSG_HEADER;
     }
-    if (auth->stat.write == MQTT_MSG_BEGIN) {
+    if (auth->stat.write == MQTT_MSG_HEADER) {
         int xfer = client->write.len;
 
         /* Send authentication packet */