public void assertSubscriptions ( ) { for ( String channel : subscribers . keySet ( ) ) { try { subscribers . put ( channel , null ) ; subscribe ( channel ) ; } catch ( Throwable e ) { break ; } } }
Reassert subscriptions .