protected void unsubscribe ( String id , MessagingContext ctx ) throws IOException { if ( ! canProceed ( ) ) return ; Set < MessagingContext > sub = this . routingContext . subscriptions . get ( id ) ; if ( sub != null ) { sub . remove ( ctx ) ; if ( sub . isEmpty ( ) ) this . routingContext . subscriptions . remove ( id ) ; } }
Unregisters a subscription between an ID and a context .