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 147315c commit 5fc140aCopy full SHA for 5fc140a
src/test/java/com/rabbitmq/stream/perf/StreamPerfTestTest.java
@@ -400,7 +400,11 @@ void waitUntilStreamExists(String stream) throws Exception {
400
}
401
402
Future<?> run(ArgumentsBuilder builder) {
403
- AddressResolver addressResolver = address -> new Address("localhost", Client.DEFAULT_PORT);
+ AddressResolver addressResolver =
404
+ address ->
405
+ address.port() == Client.DEFAULT_PORT
406
+ ? new Address("localhost", Client.DEFAULT_PORT)
407
+ : new Address("localhost", Client.DEFAULT_TLS_PORT);
408
return executor.submit(
409
() ->
410
exitCode.set(
0 commit comments