private void terminateSubscriptions ( IoSession session , Subscription . CloseReason reason ) { Multiset < String > heapsForThisClient ; try { subTermLock . lock ( ) ; heapsForThisClient = heapsByClient . remove ( session ) ; } finally { subTermLock . unlock ( ) ; } if ( heapsForThisClient != null ) { for ( String s : heapsForThisClient . keySet ( ) ) { terminateSubscriptions ( session , s , reason ) ; } } }
Terminates all subscriptions for a given client