diff --git a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/CommsCallback.java b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/CommsCallback.java
index 7e7cdd7a..037b989f 100644
--- a/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/CommsCallback.java
+++ b/org.eclipse.paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/CommsCallback.java
@@ -639,6 +639,7 @@ protected boolean deliverMessage(String topicName, int messageId, MqttMessage aM
 				// Just log the fact that an exception was thrown
 				// @TRACE 725=Ignoring Exception thrown from messageArrived: {0}
 				log.fine(CLASS_NAME, methodName, "725", new Object[] { ex });
+				throw ex;
 			}
 			delivered = true;
 		}