From 36c2753a9a44dfe2571b143642b0d3c81355881f Mon Sep 17 00:00:00 2001 From: Jason Tedor Date: Tue, 10 Oct 2017 11:07:27 -0400 Subject: [PATCH] More formatting --- .../org/elasticsearch/transport/netty4/Netty4Transport.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/modules/transport-netty4/src/main/java/org/elasticsearch/transport/netty4/Netty4Transport.java b/modules/transport-netty4/src/main/java/org/elasticsearch/transport/netty4/Netty4Transport.java index 6fda307a0b3d9..84c86bd2d770a 100644 --- a/modules/transport-netty4/src/main/java/org/elasticsearch/transport/netty4/Netty4Transport.java +++ b/modules/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 onChannelClose) { + protected NodeChannels connectToChannels(DiscoveryNode node, ConnectionProfile profile, Consumer 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";