class OvsdbConnectionHandler extends ChannelInboundHandlerAdapter {

  @Override
  public void channelRead(ChannelHandlerContext ctx, Object msg) {
    readIdleCount = 0;
    // Don't send heartbeat response to user
    if (!isHeartbeatResponse((JsonNode) msg)) {
      ctx.fireChannelRead(msg);
    } else {
      LOGGER.debug("Received heartbeat response {}", msg);
    }
  }

    OvsdbConnectionHandler(
      ConnectionCallback connectionCallback, ScheduledExecutorService executorService
  );
    OvsdbConnectionHandler(
      CompletableFuture<OvsdbClient> ovsdbClientFuture, ScheduledExecutorService executorService
  );
  private  OvsdbConnectionHandler(
      CompletableFuture<OvsdbClient> ovsdbClientFuture, ConnectionCallback connectionCallback,
      ScheduledExecutorService executorService
  );

}