Fix unit test

acogoluegnes · acogoluegnes · commit fdd59fff423b · 2024-11-28T18:44:50.000+01:00
diff --git a/src/test/java/com/rabbitmq/stream/impl/StreamEnvironmentUnitTest.java b/src/test/java/com/rabbitmq/stream/impl/StreamEnvironmentUnitTest.java
@@ -245,7 +245,7 @@ void locatorOperationShouldThrowLocatorExceptionWhenRetryExhausts() {
                     CLIENT_SUPPLIER,
                     BackOffDelayPolicy.fixed(Duration.ofMillis(10))))
         .isInstanceOf(LocatorNotAvailableException.class);
-    assertThat(counter).hasValue(3);
+    assertThat(counter).hasValue(5);
   }
 
   @Test

Original file line number	Diff line number	Diff line change
`@@ -245,7 +245,7 @@ void locatorOperationShouldThrowLocatorExceptionWhenRetryExhausts() {`
`245`	`245`	`CLIENT_SUPPLIER,`
`246`	`246`	`BackOffDelayPolicy.fixed(Duration.ofMillis(10))))`
`247`	`247`	`.isInstanceOf(LocatorNotAvailableException.class);`
`248`		`- assertThat(counter).hasValue(3);`
	`248`	`+ assertThat(counter).hasValue(5);`
`249`	`249`	`}`
`250`	`250`
`251`	`251`	`@Test`