code: @Override
      public void init(CollectorManager collectorManager) {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) {
              Tr.event(tc, "Subscribing to sources " + this, taskMap.keySet());
          }
          try {
              this.collectorMgr = collectorManager;
              //Get the source Ids from the task map and subscribe to relevant sources
              collectorMgr.subscribe(this, new ArrayList<String>(taskMap.keySet()));
          } catch (Exception e) {
  
          } finally {
              latch.countDown();
          }
      }
docs: Methods from the collector manager handler interface