Added payload size check if publish is extended as will

hivemq · Dec 15, 2019 · 4bf1449 · 4bf1449
1 parent d2b4aeb
commit 4bf1449
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/com/hivemq/client/internal/mqtt/message/publish/MqttPublishBuilder.java b/src/main/java/com/hivemq/client/internal/mqtt/message/publish/MqttPublishBuilder.java
@@ -262,6 +262,8 @@ private static abstract class WillBase<B extends WillBase<B>> extends MqttPublis
             super(publishBuilder);
             if (publishBuilder instanceof WillBase) {
                 delayInterval = ((WillBase<?>) publishBuilder).delayInterval;
+            } else {
+                payload(payload); // check payload size restriction
             }
         }