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 ) ; }
Close a flow . This is invoked when the ClientConnection is closed .