Skip to content

Commit fd0660e

Browse files
committed
Activate Netty with ConnectionFactory#netty()
1 parent c2dc323 commit fd0660e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/test/java/com/rabbitmq/perf/it/ConnectionRecoveryIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ static Arguments[] blockingIoAndNetty(
107107
arguments.add(
108108
Arguments.of(
109109
configurer, namedConsumer("blocking IO", (Consumer<ConnectionFactory>) cf -> {})));
110-
arguments.add(Arguments.of(configurer, namedConsumer("Netty", ConnectionFactory::useNetty)));
110+
arguments.add(Arguments.of(configurer, namedConsumer("Netty", ConnectionFactory::netty)));
111111
}
112112

113113
return arguments.toArray(new Arguments[0]);
@@ -300,7 +300,7 @@ public void shouldRecoverWithNetty(TestInfo info) throws Exception {
300300
params.setQueueNames(Arrays.asList("one", "two", "three"));
301301
params.setProducerCount(10);
302302
params.setConsumerCount(10);
303-
cf.useNetty();
303+
cf.netty();
304304
int producerConsumerCount = params.getProducerCount();
305305
MulticastSet set =
306306
new MulticastSet(performanceMetrics, cf, params, "", URIS, latchCompletionHandler(1, info));

0 commit comments

Comments
 (0)