diff --git a/core/src/main/java/org/elasticsearch/transport/TcpTransport.java b/core/src/main/java/org/elasticsearch/transport/TcpTransport.java index d5aed81ae805b..0bf600cb02928 100644 --- a/core/src/main/java/org/elasticsearch/transport/TcpTransport.java +++ b/core/src/main/java/org/elasticsearch/transport/TcpTransport.java @@ -278,13 +278,13 @@ public void setTransportService(TransportService service) { this.transportService = service; } - private static class HandshakeResponseHandler implements TransportResponseHandler { + private static class HandshakeResponseHandler implements TransportResponseHandler { final AtomicReference versionRef = new AtomicReference<>(); final CountDownLatch latch = new CountDownLatch(1); final AtomicReference exceptionRef = new AtomicReference<>(); - final Channel channel; + final TcpChannel channel; - HandshakeResponseHandler(Channel channel) { + HandshakeResponseHandler(TcpChannel channel) { this.channel = channel; }