public void removeSubscriptions ( ) { for ( TopicSubscriber subscriber : subscribers . values ( ) ) { try { subscriber . close ( ) ; } catch ( Throwable e ) { log . debug ( "Error closing subscriber" , e ) ; //is level appropriate - previously hidden exception -afranken } } subscribers . clear ( ) ; }
Remove all remote subscriptions .