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 2b2acf9 commit 47c7909Copy full SHA for 47c7909
src/test/java/com/rabbitmq/stream/impl/StreamConsumerTest.java
@@ -224,7 +224,6 @@ void consumeWithAsyncConsumerFlowControl() throws Exception {
224
messageContexts.add(context);
225
}
226
});
227
- long start = System.nanoTime();
228
Consumer consumer = consumerBuilder.build();
229
230
waitAtMost(() -> receivedMessageCount.get() >= processingLimit);
0 commit comments