diff --git a/src/MQTTAsyncUtils.c b/src/MQTTAsyncUtils.c
index 6d933040..15c4239f 100644
--- a/src/MQTTAsyncUtils.c
+++ b/src/MQTTAsyncUtils.c
@@ -3078,7 +3078,15 @@ static MQTTPacket* MQTTAsync_cycle(SOCKET* sock, unsigned long timeout, int* rc)
 				else if (msgtype == PUBREC)
 					*rc = MQTTProtocol_handlePubrecs(pack, *sock, &pubToRemove);
 				else if (msgtype == PUBACK)
+				{
 					*rc = MQTTProtocol_handlePubacks(pack, *sock, &pubToRemove);
+					if (sendThread_state != STOPPED)
+#if !defined(_WIN32) && !defined(_WIN64)
+						Thread_signal_cond(send_cond);
+#else
+						Thread_post_sem(send_sem);
+#endif
+				}
 				if (!m)
 					Log(LOG_ERROR, -1, "PUBCOMP, PUBACK or PUBREC received for no client, msgid %d", msgid);
 				if (m && (msgtype != PUBREC || ackrc >= MQTTREASONCODE_UNSPECIFIED_ERROR))