code: private ConsumerDispatcher createConsumerDispatcher(
                                                          ConsumerDispatcherState state,
                                                          SubscriptionItemStream subscription)
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(
                          tc,
                          "createConsumerDispatcher",
                          new Object[] { state, subscription });
  
          /*
           * Now create the consumer dispatcher,
           * passing it the subscription reference stream that has been created
           */
          final ConsumerDispatcher newConsumerDispatcher =
                          new ConsumerDispatcher(_baseDestinationHandler, subscription, state);
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "createConsumerDispatcher", newConsumerDispatcher);
  
          return newConsumerDispatcher;
      }
docs: <p>This method is used to create a consumer dispatcher for subscriptions
  A subscription can be either durable
  or non-durable. If the subscription is durable, the reference stream
  should be persistent, otherwise it can be a
  temporary reference stream.</p>
  
  @param state The state object
  @param subscription The subscription referenceStream to pass to the
  Consumer Dispatcher.
  @return ConsumerDispatcher The created Consumer dispatcher