diff --git a/modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/pipelining/HttpPipeliningHandler.java b/modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/pipelining/HttpPipeliningHandler.java index 1b955f0e00e..9504d4c7d91 100644 --- a/modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/pipelining/HttpPipeliningHandler.java +++ b/modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/pipelining/HttpPipeliningHandler.java @@ -45,6 +45,7 @@ public class HttpPipeliningHandler extends ChannelDuplexHandler { private int readSequence; private int writeSequence; + // we use a priority queue so that responses are ordered by their sequence number private final PriorityQueue holdingQueue; /** @@ -55,7 +56,6 @@ public class HttpPipeliningHandler extends ChannelDuplexHandler { */ public HttpPipeliningHandler(final int maxEventsHeld) { this.maxEventsHeld = maxEventsHeld; - // we use a priority queue so that responses are ordered by their sequence number this.holdingQueue = new PriorityQueue<>(INITIAL_EVENTS_HELD); }