@Override
    public void operationComplete(ChannelFuture future) throws InterruptedException {
      if (isOpen.get()) {
        createChannel();
      }
      invokeFutureAndCallback("ChannelCloseListener::operationComplete");
    }
Listens to close of a channel and initiates connect for a new channel.
ambry-test-utils/src/main/java/com/github/ambry/rest/NettyClient.java