code: public void closeFlow(ClientConnection clientConnection) {
          final ClientConnectionImpl clientConnectionImpl = (ClientConnectionImpl) clientConnection;
          int flow = clientConnectionImpl.getFlowId();
          log.info("Closing Flow {} for endpoint {}", flow, clientConnectionImpl.getConnectionName());
          flowIdReplyProcessorMap.remove(flow);
      }
docs: Close a flow. This is invoked when the ClientConnection is closed.
  @param clientConnection Client Connection.