docs: private ConsumerDispatcher createSubscriptionItemStreamAndConsumerDispatcher(ConsumerDispatcherState subState, boolean isShared)
                      throws SIResourceException, SIDiscriminatorSyntaxException, SISelectorSyntaxException
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "createSubscriptionItemStreamAndConsumerDispatcher", new Object[] { subState, isShared });
  
          // Now attempt to create the item stream
          SubscriptionItemStream subscription = null;
          ConsumerDispatcher cd = null;
  
          try
          {
              // 174199.2.9
              // Temporary non-persistent topicspaces require non-persistent
              // consumer dispatchers.
              subscription =
                              new SubscriptionItemStream(
                                              _pubsubMessageItemStream,
                                              _baseDestinationHandler.getTransactionManager());
          } catch (OutOfCacheSpace e)
          {
              // No FFDC code needed
              SibTr.exception(tc, e);
  
              if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                  SibTr.exit(tc, "createSubscriptionItemStreamAndConsumerDispatcher", e);
  
              throw new SIResourceException(
                              nls.getFormattedMessage(
                                                      "SUBSCRIPTION_CREATION_FAILED_CWSIP0034",
                                                      new Object[] { _baseDestinationHandler.getName(), e },
                                                      null),
                              e);
          } catch (MessageStoreException e)
          {
              // MessageStoreException shouldn't occur so FFDC.
              FFDCFilter.processException(
                                          e,
                                          "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.createSubscriptionItemStreamAndConsumerDispatcher",
                                          "1:763:1.35.2.4",
                                          this);
  
              SibTr.exception(tc, e);
  
              // Write the error to the console
              SibTr.error(
                          tc,
                          "SUBSCRIPTION_CREATION_FAILED_CWSIP0031",
                          new Object[] { _baseDestinationHandler.getName(), e });
  
              /*
               * The message store has thrown an exception, which leaves us stuck. Record an ffst,
               * write a trace record and throw a SIResourceException to the caller.
               */
              if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                  SibTr.exit(tc, "createSubscriptionItemStreamAndConsumerDispatcher", e);
  
              throw new SIResourceException(
                              nls.getFormattedMessage(
                                                      "SUBSCRIPTION_CREATION_FAILED_CWSIP0031",
                                                      new Object[] { _baseDestinationHandler.getName(), e },
                                                      null),
                              e);
          }
  
          cd = createConsumerDispatcher(subState, subscription);
  
          // Store the CD in the MatchSpace
          _messageProcessor
                          .getMessageProcessorMatching()
                          .addConsumerDispatcherMatchTarget(
                                                            cd,
                                                            _baseDestinationHandler.getUuid(),
                                                            subState.getSelectionCriteria());
  
          //store cd into hash map only in case if the consumer is shared. 
          // All non-durable shared consumer's subscriberID do not start with _NON_DURABLE_NON_SHARED
          if (!subState.getSubscriberID().contains("_NON_DURABLE_NON_SHARED"))
              _destinationManager.getNondurableSharedSubscriptions().put(subState.getSubscriberID(), cd);
  
          // 166833.2
          // Generate the subscribeEvent for this new subscription
          // to see if this needs to be forwarded to a Neighbouring ME.
          //venu liberty change
          //_messageProcessor.getProxyHandler().subscribeEvent(subState, null);
  
          _subscriptionIndex.put(cd);
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "createSubscriptionItemStreamAndConsumerDispatcher", cd);
  
          return cd;
  
      }