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 8115ef3 commit be772c2Copy full SHA for be772c2
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