Merge pull request #2437 from cescoffier/mqtt-will-message-bytes

Add support for the willMessageBytes method
smallrye · Jan 3, 2024 · 04f12f9 · 04f12f9
2 parents 65c427f + cebf931
commit 04f12f9
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/...t/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java b/...t/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java
@@ -120,11 +120,18 @@ public MqttClientSessionOptions setWillTopic(String willTopic) {
     }
 
     @Override
+    @Deprecated
     public MqttClientSessionOptions setWillMessage(String willMessage) {
         super.setWillMessage(willMessage);
         return this;
     }
 
+    @Override
+    public MqttClientOptions setWillMessageBytes(Buffer willMessage) {
+        super.setWillMessageBytes(willMessage);
+        return this;
+    }
+
     @Override
     public MqttClientSessionOptions setCleanSession(boolean cleanSession) {
         super.setCleanSession(cleanSession);