We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1580b8e commit d4e3af8Copy full SHA for d4e3af8
src/test/java/com/rabbitmq/stream/impl/ConsumersCoordinatorTest.java
@@ -329,7 +329,9 @@ void subscribePropagateExceptionWhenClientSubscriptionFails() {
329
OffsetSpecification.first(),
330
null,
331
NO_OP_SUBSCRIPTION_LISTENER,
332
- (offset, message) -> {}))
+ NO_OP_TRACKING_CLOSING_CALLBACK,
333
+ (offset, message) -> {},
334
+ Collections.emptyMap()))
335
.isInstanceOf(StreamException.class)
336
.hasMessage(exceptionMessage);
337
assertThat(MonitoringTestUtils.extract(coordinator)).isEmpty();
0 commit comments