diff --git a/MQTTSNGateway/src/MQTTSNGWPacketHandleTask.cpp b/MQTTSNGateway/src/MQTTSNGWPacketHandleTask.cpp index a4c8718..f195d76 100644 --- a/MQTTSNGateway/src/MQTTSNGWPacketHandleTask.cpp +++ b/MQTTSNGateway/src/MQTTSNGWPacketHandleTask.cpp @@ -198,6 +198,9 @@ void PacketHandleTask::aggregatePacketHandler(Client*client, MQTTSNPacket* packe case MQTTSN_DISCONNECT: _mqttsnAggrConnection->handleDisconnect(client, packet); break; + case MQTTSN_WILLTOPICUPD: + _mqttsnConnection->handleWilltopicupd(client, packet); + break; case MQTTSN_WILLMSGUPD: _mqttsnConnection->handleWillmsgupd(client, packet); break; @@ -289,6 +292,9 @@ void PacketHandleTask::transparentPacketHandler(Client*client, MQTTSNPacket* pac case MQTTSN_DISCONNECT: _mqttsnConnection->handleDisconnect(client, packet); break; + case MQTTSN_WILLTOPICUPD: + _mqttsnConnection->handleWilltopicupd(client, packet); + break; case MQTTSN_WILLMSGUPD: _mqttsnConnection->handleWillmsgupd(client, packet); break;