Skip to content

Commit 8bf7c8f

Browse files
committed
Avoid Exceptions for persist Buffered Message
Signed-off-by: ogis-yamazaki <Yamazaki_Shoji@ogis-ri.co.jp>
1 parent 17fd7be commit 8bf7c8f

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

  • org.eclipse.paho.client.mqttv3/src/main/java-templates/org/eclipse/paho/client/mqttv3/internal

org.eclipse.paho.client.mqttv3/src/main/java-templates/org/eclipse/paho/client/mqttv3/internal/ClientComms.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,9 @@ public void sendNoWait(MqttWireMessage message, MqttToken token) throws MqttExce
186186
//@TRACE 507=Client Connected, Offline Buffer available, but not empty. Adding message to buffer. message={0}
187187
log.fine(CLASS_NAME, methodName, "507", new Object[] {message.getKey()});
188188
if(disconnectedMessageBuffer.isPersistBuffer()){
189-
this.clientState.persistBufferedMessage(message);
189+
if (message instanceof MqttPublish) {
190+
this.clientState.persistBufferedMessage(message);
191+
}
190192
}
191193
disconnectedMessageBuffer.putMessage(message, token);
192194
} else {

0 commit comments

Comments
 (0)