code: public void stop() {
      instanceLock.writeLock().lock();
      try {
        for (final NamespaceChangeStreamListener streamer : nsStreamers.values()) {
          streamer.stop();
        }
      } finally {
        instanceLock.writeLock().unlock();
      }
    }
docs: Stops all streams.