Added forgotten case

2 years ago · 52b2c5f9eb
1 changed files with 4 additions and 0 deletions
--- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
+++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
@ -317,6 +317,10 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
                MqttSubscribeMessage subscribeMessage = (MqttSubscribeMessage) msg;
                processSubscribe(ctx, subscribeMessage);
                break;
+            case UNSUBSCRIBE:
+                MqttUnsubscribeMessage unsubscribeMessage = (MqttUnsubscribeMessage) msg;
+                processUnsubscribe(ctx, unsubscribeMessage);
+                break;
            case PINGREQ:
                ctx.writeAndFlush(new MqttMessage(new MqttFixedHeader(PINGRESP, false, AT_MOST_ONCE, false, 0)));
                break;