diff --git a/src/main/java/io/nats/client/impl/MessageQueue.java b/src/main/java/io/nats/client/impl/MessageQueue.java
index 35f031ad9..e516e7a71 100644
--- a/src/main/java/io/nats/client/impl/MessageQueue.java
+++ b/src/main/java/io/nats/client/impl/MessageQueue.java
@@ -167,7 +167,8 @@ boolean push(NatsMessage msg, boolean internal) {
             }
         }
         catch (InterruptedException e) {
-            return false;
+            Thread.currentThread().interrupt();
+            throw new RuntimeException(e);
         }
 
         try {