diff --git a/tests/NATS.Client.JetStream.Tests/ErrorHandlerTest.cs b/tests/NATS.Client.JetStream.Tests/ErrorHandlerTest.cs
index c007cfb0d..da264a0db 100644
--- a/tests/NATS.Client.JetStream.Tests/ErrorHandlerTest.cs
+++ b/tests/NATS.Client.JetStream.Tests/ErrorHandlerTest.cs
@@ -313,12 +313,13 @@ public async Task Exception_propagation_handling()
 
         var stream = await js.CreateStreamAsync(new StreamConfig("s1", new[] { "s1.*" }), cts.Token);
 
+        // reduce heartbeat time out to increase the chance of receiving notification.
         var opts = new NatsJSConsumeOpts
         {
             MaxMsgs = 10,
             NotificationHandler = (_, _) => throw new TestConsumerNotificationException(),
             Expires = TimeSpan.FromSeconds(6),
-            IdleHeartbeat = TimeSpan.FromSeconds(3),
+            IdleHeartbeat = TimeSpan.FromSeconds(1),
         };
 
         // Swallow heartbeats
@@ -331,7 +332,7 @@ public async Task Exception_propagation_handling()
             {
             }
 
-            throw new Exception("Should have thrown");
+            throw new Exception("Should have thrown (consumer)");
         }
         catch (TestConsumerNotificationException)
         {
@@ -344,7 +345,7 @@ public async Task Exception_propagation_handling()
             {
             }
 
-            throw new Exception("Should have thrown");
+            throw new Exception("Should have thrown (ordered consumer)");
         }
         catch (TestConsumerNotificationException)
         {