code: @Override
      public ConsumerManager createConsumerManager()
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "createConsumerManager");
  
          ConsumerDispatcher consumerDispatcher = (ConsumerDispatcher) getOutputHandler();
          if (consumerDispatcher == null)
          {
              consumerDispatcher = new ConsumerDispatcher(destinationHandler, this, new ConsumerDispatcherState());
              setOutputHandler(consumerDispatcher);
          }
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "createConsumerManager", consumerDispatcher);
          return consumerDispatcher;
      }
docs: /*
  (non-Javadoc)