code: public void removeSubscribedSource(Source source) {
          String sourceId = CollectorManagerUtils.getSourceId(source);
          subscribedSources.remove(sourceId);
      }
docs: /*
  Method to remove a subscribed source.