@@ -654,12 +654,12 @@ public Connection newConnection(Address[] addrs) throws IOException, TimeoutExce
654
654
* is enabled, the connection returned by this method will be {@link Recoverable}. Future
655
655
* reconnection attempts will pick a random accessible address from the provided list.
656
656
*
657
- * @param addr_list a List of known broker addresses (hostname/port pairs) to try in order
657
+ * @param addrs a List of known broker addresses (hostname/port pairs) to try in order
658
658
* @return an interface to the connection
659
659
* @throws IOException if it encounters a problem
660
660
*/
661
- public Connection newConnection (List <Address > addr_list ) throws IOException , TimeoutException {
662
- return newConnection (this .sharedExecutor , addr_list );
661
+ public Connection newConnection (List <Address > addrs ) throws IOException , TimeoutException {
662
+ return newConnection (this .sharedExecutor , addrs );
663
663
}
664
664
665
665
/**
@@ -689,26 +689,26 @@ public Connection newConnection(ExecutorService executor, Address[] addrs) throw
689
689
* reconnection attempts will pick a random accessible address from the provided list.
690
690
*
691
691
* @param executor thread execution service for consumers on the connection
692
- * @param addr_list a List of known broker addresses (hostname/port pairs) to try in order
692
+ * @param addrs a List of known broker addrs (hostname/port pairs) to try in order
693
693
* @return an interface to the connection
694
694
* @throws java.io.IOException if it encounters a problem
695
695
* @see <a href="http://www.rabbitmq.com/api-guide.html#recovery">Automatic Recovery</a>
696
696
*/
697
- public Connection newConnection (ExecutorService executor , List <Address > addr_list )
697
+ public Connection newConnection (ExecutorService executor , List <Address > addrs )
698
698
throws IOException , TimeoutException {
699
699
// make sure we respect the provided thread factory
700
700
FrameHandlerFactory fhFactory = createFrameHandlerFactory ();
701
701
ConnectionParams params = params (executor );
702
702
703
703
if (isAutomaticRecoveryEnabled ()) {
704
704
// see com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory#newConnection
705
- AutorecoveringConnection conn = new AutorecoveringConnection (params , fhFactory , addr_list );
705
+ AutorecoveringConnection conn = new AutorecoveringConnection (params , fhFactory , addrs );
706
706
707
707
conn .init ();
708
708
return conn ;
709
709
} else {
710
710
IOException lastException = null ;
711
- for (Address addr : addr_list ) {
711
+ for (Address addr : addrs ) {
712
712
try {
713
713
FrameHandler handler = fhFactory .create (addr );
714
714
AMQConnection conn = new AMQConnection (params , handler );
0 commit comments