code: 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();
      }
docs: Remove all remote subscriptions.