HBASE-27271 Addendum use NettyFutureUtils

apache · Aug 4, 2022 · 2ac5578 · 2ac5578
1 parent 2dc2608
commit 2ac5578
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java
@@ -239,7 +239,7 @@ public void operationComplete(Future<Boolean> future) throws Exception {
             p.addBefore(BufferCallBeforeInitHandler.NAME, readTimeoutHandlerName,
               new ReadTimeoutHandler(RpcClient.DEFAULT_SOCKET_TIMEOUT_READ, TimeUnit.MILLISECONDS))
               .addBefore(BufferCallBeforeInitHandler.NAME, null, chHandler);
-            connectionHeaderPromise.addListener(new FutureListener<Boolean>() {
+            NettyFutureUtils.addListener(connectionHeaderPromise, new FutureListener<Boolean>() {
               @Override
               public void operationComplete(Future<Boolean> future) throws Exception {
                 if (future.isSuccess()) {