8000 Cosmetics · ThinkLib/rabbitmq-java-client@c67d868 · GitHub
[go: up one dir, main page]

Skip to content

Commit c67d868

Browse files
Cosmetics
1 parent be7540d commit c67d868

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

src/com/rabbitmq/client/ConnectionFactory.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -654,12 +654,12 @@ public Connection newConnection(Address[] addrs) throws IOException, TimeoutExce
654654
* is enabled, the connection returned by this method will be {@link Recoverable}. Future
655655
* reconnection attempts will pick a random accessible address from the provided list.
656656
*
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
658658
* @return an interface to the connection
659659
* @throws IOException if it encounters a problem
660660
*/
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);
663663
}
664664

665665
/**
@@ -689,26 +689,26 @@ public Connection newConnection(ExecutorService executor, Address[] addrs) throw
689689
* reconnection attempts will pick a random accessible address from the provided list.
690690
*
691691
* @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
693693
* @return an interface to the connection
694694
* @throws java.io.IOException if it encounters a problem
695695
* @see <a href="http://www.rabbitmq.com/api-guide.html#recovery">Automatic Recovery</a>
696696
*/
697-
public Connection newConnection(ExecutorService executor, List<Address> addr_list)
697+
public Connection newConnection(ExecutorService executor, List<Address> addrs)
698698
throws IOException, TimeoutException {
699699
// make sure we respect the provided thread factory
700700
FrameHandlerFactory fhFactory = createFrameHandlerFactory();
701701
ConnectionParams params = params(executor);
702702

703703
if (isAutomaticRecoveryEnabled()) {
704704
// 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);
706706

707707
conn.init();
708708
return conn;
709709
} else {
710710
IOException lastException = null;
711-
for (Address addr : addr_list) {
711+
for (Address addr : addrs) {
712712
try {
713713
FrameHandler handler = fhFactory.create(addr);
714714
AMQConnection conn = new AMQConnection(params, handler);

0 commit comments

Comments
 (0)
0