Test flapper fixes (#268)

nats-io · Dec 1, 2023 · a14aa05 · a14aa05
1 parent d08190d
commit a14aa05
Showing 1 changed file with 4 additions and 3 deletions.
diff --git 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)
         {