code: public void shutdown() {
      synchronized (omap) {
        for (Map.Entry<TapStream, TapConnectionProvider> me : omap.entrySet()) {
          me.getValue().shutdown();
        }
      }
    }
docs: Shuts down all tap streams that are currently running.