Skip to content

Commit 865d24a

Browse files
author
Ranjan Dasgupta
authored
Merge pull request #730 from ogis-yamazaki/get_msgid_with_persist_buffer
get message id from token with DisconnectedMessageBuffer when offline publish
2 parents 1135b83 + 9f551f7 commit 865d24a

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)