More formatting

jasontedor · Oct 10, 2017 · 36c2753 · 36c2753
1 parent 78ff3d6
commit 36c2753
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/...es/transport-netty4/src/main/java/org/elasticsearch/transport/netty4/Netty4Transport.java b/...es/transport-netty4/src/main/java/org/elasticsearch/transport/netty4/Netty4Transport.java
@@ -252,8 +252,7 @@ public long getNumOpenServerConnections() {
     }
 
     @Override
-    protected NodeChannels connectToChannels(
-            DiscoveryNode node, ConnectionProfile profile, Consumer<Channel> onChannelClose) {
+    protected NodeChannels connectToChannels(DiscoveryNode node, ConnectionProfile profile, Consumer<Channel> onChannelClose) {
         final Channel[] channels = new Channel[profile.getNumConnections()];
         final NodeChannels nodeChannels = new NodeChannels(node, channels, profile);
         boolean success = false;
@@ -284,8 +283,7 @@ protected NodeChannels connectToChannels(
                     if (!future.isSuccess()) {
                         throw new ConnectTransportException(node, "connect_timeout[" + connectTimeout + "]", future.cause());
                     }
-                    final Channel channel = future.channel();
-                    channels[i] = channel;
+                    channels[i] = future.channel();
                     channels[i].closeFuture().addListener(closeListener);
                 }
                 assert iterator.hasNext() == false : "not all created connection have been consumed";