Skip to content

Commit a975c3e

Browse files
Specifically invoke the Address[] version
Otherwise we test a test helper method.
1 parent 5edfb82 commit a975c3e

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

src/test/java/com/rabbitmq/client/test/functional/ConnectionRecovery.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -721,15 +721,11 @@ private AutorecoveringConnection newRecoveringConnection(boolean disableTopology
721721
return (AutorecoveringConnection) cf.newConnection();
722722
}
723723

724-
private AutorecoveringConnection newRecoveringConnection(boolean disableTopologyRecovery, Address[] addresses)
725-
throws IOException, TimeoutException {
726-
ConnectionFactory cf = buildConnectionFactoryWithRecoveryEnabled(disableTopologyRecovery);
727-
return (AutorecoveringConnection) cf.newConnection(addresses);
728-
}
729-
730724
private AutorecoveringConnection newRecoveringConnection(Address[] addresses)
731725
throws IOException, TimeoutException {
732-
return newRecoveringConnection(false, Arrays.asList(addresses));
726+
ConnectionFactory cf = buildConnectionFactoryWithRecoveryEnabled(false);
727+
// specifically use the Address[] overload
728+
return (AutorecoveringConnection) cf.newConnection(addresses);
733729
}
734730

735731
private AutorecoveringConnection newRecoveringConnection(boolean disableTopologyRecovery, List<Address> addresses)

0 commit comments

Comments
 (0)