diff --git a/src/MQTTProtocolClient.c b/src/MQTTProtocolClient.c index 4c4767e5..d7c8f985 100644 --- a/src/MQTTProtocolClient.c +++ b/src/MQTTProtocolClient.c @@ -330,12 +330,13 @@ int MQTTProtocol_handlePublishes(void* pack, int sock) int already_received = 0; ListElement* listElem = NULL; Messages* m = malloc(sizeof(Messages)); + Publications* p = NULL; if (!m) { rc = PAHO_MEMORY_ERROR; goto exit; } - Publications* p = MQTTProtocol_storePublication(publish, &len); + p = MQTTProtocol_storePublication(publish, &len); m->publish = p; m->msgid = publish->msgId;