From 8361040aec4216973e0cc4acc3cfc667ab85c389 Mon Sep 17 00:00:00 2001 From: Johannes Schriewer Date: Mon, 30 Jul 2018 22:27:00 +0200 Subject: [PATCH] BUGFIX: Wat?! Ok this was clearly copy and paste... --- src/protocol.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/protocol.c b/src/protocol.c index 45ec6c5..bc81b30 100644 --- a/src/protocol.c +++ b/src/protocol.c @@ -73,8 +73,8 @@ bool send_subscribe_packet(MQTTHandle *handle, char *topic, MQTTQosLevel qos) { bool send_unsubscribe_packet(MQTTHandle *handle, char *topic) { UnsubscribePayload *payload = calloc(1, sizeof(UnsubscribePayload)); - payload->packet_id = 10; - payload->topic = "test/topic"; + payload->packet_id = (++handle->packet_id_counter > 0) ? handle->packet_id_counter : ++handle->packet_id_counter; + payload->topic = topic; Buffer *encoded = mqtt_packet_encode(&(MQTTPacket){ PacketTypeUnsubscribe, payload });