Commit 2ceffbc7 authored by Juergen Kosel's avatar Juergen Kosel

Moved the decrement of pendingMessageCnt to another call back function

For some unknown reason, decrementing pendingMessageCnt in
test373DeliveryComplete() does not work. Therefore moved to other call
back functions.
Signed-off-by: 's avatarJuergen Kosel <juergen.kosel@softing.com>
parent cdd7f0e4
...@@ -206,16 +206,17 @@ void test373ConnectionLost(void* context, char* cause) ...@@ -206,16 +206,17 @@ void test373ConnectionLost(void* context, char* cause)
void test373DeliveryComplete(void* context, MQTTAsync_token token) void test373DeliveryComplete(void* context, MQTTAsync_token token)
{ {
pendingMessageCnt--;
} }
void test373_onWriteSuccess(void* context, MQTTAsync_successData* response) void test373_onWriteSuccess(void* context, MQTTAsync_successData* response)
{ {
pendingMessageCnt--;
goodPublishCnt++; goodPublishCnt++;
} }
void test373_onWriteFailure(void* context, MQTTAsync_failureData* response) void test373_onWriteFailure(void* context, MQTTAsync_failureData* response)
{ {
pendingMessageCnt--;
failedPublishCnt++; failedPublishCnt++;
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment