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 474088e commit 7487903Copy full SHA for 7487903
src/test/java/com/rabbitmq/client/amqp/impl/TopologyRecoveryTest.java
@@ -477,7 +477,7 @@ void recoverConsumers(boolean isolateResources) {
477
connection.management().exchange(e).type(FANOUT).declare();
478
connection.management().queue(q).declare();
479
connection.management().binding().sourceExchange(e).destinationQueue(q).bind();
480
- int consumerCount = 100;
+ int consumerCount = 60;
481
TestUtils.Sync consumeSync = TestUtils.sync(consumerCount);
482
Consumer.MessageHandler handler =
483
(ctx, m) -> {
0 commit comments