Skip to content

Commit ee6fe3d

Browse files
committed
Throw exception when no message ids available in persistBufferedMessage, and fix typo warning message.
Signed-off-by: ogis-yamazaki <Yamazaki_Shoji@ogis-ri.co.jp>
1 parent 28eed43 commit ee6fe3d

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

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

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

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -582,8 +582,9 @@ else if (message instanceof MqttPubComp) {
582582
* Persists a buffered message to the persistence layer
583583
*
584584
* @param message The {@link MqttWireMessage} to persist
585+
* @throws MqttException if an exception occurs when no message ids available.
585586
*/
586-
public void persistBufferedMessage(MqttWireMessage message) {
587+
public void persistBufferedMessage(MqttWireMessage message) throws MqttException {
587588
final String methodName = "persistBufferedMessage";
588589
String key = getSendBufferedPersistenceKey(message);
589590

@@ -603,7 +604,8 @@ public void persistBufferedMessage(MqttWireMessage message) {
603604
log.fine(CLASS_NAME,methodName, "513", new Object[]{key});
604605
} catch (MqttException ex){
605606
//@TRACE 514=Failed to persist buffered message key={0}
606-
log.warning(CLASS_NAME,methodName, "513", new Object[]{key});
607+
log.warning(CLASS_NAME,methodName, "514", new Object[]{key});
608+
throw ex;
607609
}
608610
}
609611

0 commit comments

Comments
 (0)