Skip to content

Commit 9f551f7

Browse files
committed
get message id from token with DisconnectedMessageBuffer when offline publish.
Signed-off-by: ogis-yamazaki <Yamazaki_Shoji@ogis-ri.co.jp>
1 parent da0c59a commit 9f551f7

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/DisconnectedMessageBuffer.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,11 @@ public DisconnectedMessageBuffer(DisconnectedBufferOptions options) {
5353
* if the Buffer is full
5454
*/
5555
public void putMessage(MqttWireMessage message, MqttToken token) throws MqttException {
56+
if (token != null) {
57+
message.setToken(token);
58+
token.internalTok.setMessageID(message.getMessageId());
59+
}
60+
5661
BufferedMessage bufferedMessage = new BufferedMessage(message, token);
5762
synchronized (bufLock) {
5863
if (buffer.size() < bufferOpts.getBufferSize()) {

0 commit comments

Comments
 (0)