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