Merge pull request #732 from ogis-yamazaki/add_exception_when_persistBufferedMessage

throw exception when no message ids available in persistBufferedMessage.

Author: Ranjan Dasgupta

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

@@ -585,8 +585,9 @@ else if (message instanceof MqttPubComp)  {
 	 * Persists a buffered message to the persistence layer
 	 * 
 	 * @param message The {@link MqttWireMessage} to persist
+	 * @throws MqttException if an exception occurs when no message ids available.
 	 */
-	public void persistBufferedMessage(MqttWireMessage message) {
+	public void persistBufferedMessage(MqttWireMessage message) throws MqttException {
 		final String methodName = "persistBufferedMessage";
 		String key = getSendBufferedPersistenceKey(message);
 
@@ -606,7 +607,8 @@ public void persistBufferedMessage(MqttWireMessage message) {
 			log.fine(CLASS_NAME,methodName, "513", new Object[]{key});
 		} catch (MqttException ex){
 			//@TRACE 514=Failed to persist buffered message key={0}
-			log.warning(CLASS_NAME,methodName, "513", new Object[]{key});
+			log.warning(CLASS_NAME,methodName, "514", new Object[]{key});
+			throw ex;
 		} 
 	}