docs: private void processInitializedConduits(Source source) {
          String sourceId = CollectorManagerUtils.getSourceId(source);
          String sourceName = source.getSourceName();
          /*
           * Check that the current source initialized is Log/Message and Trace.
           * These are the unique special sources along with their respective Conduits/BufferManagers
           * that were started before OSGI and thusly were not configured via 'the osgi' way that CollectorManager
           * had in place before the JSON Logging work.
           */
          if (sourceName.equals(CollectorConstants.MESSAGES_SOURCE) || sourceName.equals(CollectorConstants.TRACE_SOURCE)) {
              //Make sure we have a bundleContext, we need this to play with osgi (i.e. register/listen to services)
              if (bundleContext == null) {
                  retrieveBundleContext();
              }
              /*
               * We should really check if the source and conduit/bufferManager is already set into the
               * SourceManager and BufferManager maps. If so, no need to continue the rest of this method.
               */
              if (sourceMgrs.containsKey(sourceId) && bufferManagerMap.containsKey(sourceId)) {
                  return;
              }
  
              ServiceReference<BufferManager>[] servRefs;
              try {
                  servRefs = (ServiceReference<BufferManager>[]) bundleContext.getServiceReferences(BufferManager.class.getName(), null);
                  if (servRefs != null) {
                      for (ServiceReference<BufferManager> servRef : servRefs) {
                          /*
                           * Ensure that the Conduit/BufferManager retrieved is the right one for the source
                           * by checking that the 'source' that the conduit/bufferManager was assinged to
                           * was for the Source that we are registering.
                           */
                          if (sourceName.equals(servRef.getProperty("source"))) {
                              /*
                               * Retrieve the actual Conduit/BufferManager fro mthe service Reference
                               * and put it into the bufferManagerMap.
                               */
                              Object object = bundleContext.getService(servRef);
                              BufferManager conduit = (BufferManager) object;
                              bufferManagerMap.put(sourceId, conduit);
                          }
                      }
                  }
  
              } catch (InvalidSyntaxException e) {
                  e.printStackTrace();
              }
          }
      }