Skip to content

Commit 5a2a5fd

Browse files
Cosmetics
1 parent 0b6229e commit 5a2a5fd

File tree

1 file changed

+2
-9
lines changed

1 file changed

+2
-9
lines changed

src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -74,16 +74,9 @@ public class AutorecoveringConnection implements Connection, Recoverable, Networ
7474
// This lock guards the manuallyClosed flag and the delegate connection. Guarding these two ensures that a new connection can never
7575
// be created after application code has initiated shutdown.
7676
private final Object recoveryLock = new Object();
77-
78-
public AutorecoveringConnection(ConnectionParams params, FrameHandlerFactory f, Address[] addrs) {
79-
this.cf = new RecoveryAwareAMQConnectionFactory(params, f, addrs);
80-
this.params = params;
8177

82-
this.channels = new ConcurrentHashMap<Integer, AutorecoveringChannel>();
83-
}
84-
85-
public AutorecoveringConnection(ConnectionParams params, FrameHandlerFactory f, List<Address> addr_list) {
86-
this.cf = new RecoveryAwareAMQConnectionFactory(params, f, addr_list);
78+
public AutorecoveringConnection(ConnectionParams params, FrameHandlerFactory f, List<Address> addrs) {
79+
this.cf = new RecoveryAwareAMQConnectionFactory(params, f, addrs);
8780
this.params = params;
8881

8982
this.channels = new ConcurrentHashMap<Integer, AutorecoveringChannel>();

0 commit comments

Comments
 (0)