@@ -103,8 +103,8 @@ public interface Mqtt3AsyncClient extends Mqtt3Client {
103
103
@ NotNull CompletableFuture <@ NotNull Mqtt3SubAck > subscribe (@ NotNull Mqtt3Subscribe subscribe );
104
104
105
105
/**
106
- * Subscribes this client with the given Subscribe message and consumes the the incoming Publish messages matching
107
- * the subscriptions of the Subscribe message with a callback.
106
+ * Subscribes this client with the given Subscribe message and consumes the incoming Publish messages matching the
107
+ * subscriptions of the Subscribe message with a callback.
108
108
*
109
109
* @param subscribe the Subscribe messages sent to the broker.
110
110
* @param callback the callback for consuming the incoming Publish messages matching the subscriptions of the
@@ -118,8 +118,8 @@ public interface Mqtt3AsyncClient extends Mqtt3Client {
118
118
@ NotNull Mqtt3Subscribe subscribe , @ NotNull Consumer <@ NotNull Mqtt3Publish > callback );
119
119
120
120
/**
121
- * Subscribes this client with the given Subscribe message and consumes the the incoming Publish messages matching
122
- * the subscriptions of the Subscribe message with a callback.
121
+ * Subscribes this client with the given Subscribe message and consumes the incoming Publish messages matching the
122
+ * subscriptions of the Subscribe message with a callback.
123
123
* <p>
124
124
* The future is completed and the callback is executed on the given executor.
125
125
*
@@ -137,8 +137,8 @@ public interface Mqtt3AsyncClient extends Mqtt3Client {
137
137
@ NotNull Executor executor );
138
138
139
139
/**
140
- * Subscribes this client with the given Subscribe message and consumes the the incoming Publish messages matching
141
- * the subscriptions of the Subscribe message with a callback.
140
+ * Subscribes this client with the given Subscribe message and consumes the incoming Publish messages matching the
141
+ * subscriptions of the Subscribe message with a callback.
142
142
*
143
143
* @param subscribe the Subscribe messages sent to the broker.
144
144
* @param callback the callback for consuming the incoming Publish messages matching the subscriptions
@@ -155,8 +155,8 @@ public interface Mqtt3AsyncClient extends Mqtt3Client {
155
155
boolean manualAcknowledgement );
156
156
157
157
/**
158
- * Subscribes this client with the given Subscribe message and consumes the the incoming Publish messages matching
159
- * the subscriptions of the Subscribe message with a callback.
158
+ * Subscribes this client with the given Subscribe message and consumes the incoming Publish messages matching the
159
+ * subscriptions of the Subscribe message with a callback.
160
160
* <p>
161
161
* The future is completed and the callback is executed on the given executor.
162
162
*
0 commit comments