dunkelstern/libmqtt
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

BUGFIX: Wat?! Ok this was clearly copy and paste...

Browse source
This commit is contained in:
Johannes Schriewer 2018-07-30 22:27:00 +02:00
parent dfd0a9fddf
commit 8361040aec
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/protocol.c
View file

@ -73,8 +73,8 @@ bool send_subscribe_packet(MQTTHandle *handle, char *topic, MQTTQosLevel qos) {
bool send_unsubscribe_packet(MQTTHandle *handle, char *topic) { bool send_unsubscribe_packet(MQTTHandle *handle, char *topic) {
UnsubscribePayload *payload = calloc(1, sizeof(UnsubscribePayload)); UnsubscribePayload *payload = calloc(1, sizeof(UnsubscribePayload));
payload->packet_id = 10; payload->packet_id = (++handle->packet_id_counter > 0) ? handle->packet_id_counter : ++handle->packet_id_counter;
payload->topic = "test/topic"; payload->topic = topic;
Buffer *encoded = mqtt_packet_encode(&(MQTTPacket){ PacketTypeUnsubscribe, payload }); Buffer *encoded = mqtt_packet_encode(&(MQTTPacket){ PacketTypeUnsubscribe, payload });