Exception handling

Fixed exception handling. Making sure the original connection exception is visible.
nats-io · Nov 15, 2024 · 1c1fb79 · 1c1fb79
1 parent 87cdd45
commit 1c1fb79
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/main/java/io/nats/client/impl/NatsMessageConsumer.java b/src/main/java/io/nats/client/impl/NatsMessageConsumer.java
@@ -76,13 +76,16 @@ void doSub() throws JetStreamApiException, IOException {
             finished.set(false);
         }
         catch (JetStreamApiException | IOException e) {
-            setupHbAlarmToTrigger();
+        	setupHbAlarmToTrigger();
+        	throw e;
         }
     }
 
     private void setupHbAlarmToTrigger() {
-        pmm.resetTracking();
-        pmm.initOrResetHeartbeatTimer();
+    	if ( pmm != null) {
+	        pmm.resetTracking();
+	        pmm.initOrResetHeartbeatTimer();
+    	}
     }
 
     @Override