@Override
        public void operationComplete(@NotNull ChannelFuture future) {
          try {
            Throwable cause = future.cause();
            if (cause != null) {
              LOG.warn(cause);
            }
          }
          finally {
            countDown.countDown();
          }
        }
@Override
        public void operationComplete(@NotNull ChannelFuture future)