From cebf9318acd28294a87096ca72adad75cbb23ce1 Mon Sep 17 00:00:00 2001
From: Clement Escoffier <clement.escoffier@gmail.com>
Date: Wed, 3 Jan 2024 11:55:26 +0100
Subject: [PATCH] Add support for the willMessageBytes method

---
 .../messaging/mqtt/session/MqttClientSessionOptions.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/smallrye-reactive-messaging-mqtt/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java b/smallrye-reactive-messaging-mqtt/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java
index 5ccc166cdf..b975fc5fe9 100644
--- a/smallrye-reactive-messaging-mqtt/src/main/java/io/smallrye/reactive/messaging/mqtt/session/MqttClientSessionOptions.java
+++ b/smallrye-reactive-messaging-mqtt/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);