code: public ConsumerDispatcher getDurableSubscriptionConsumerDispatcher(ConsumerDispatcherState subState)
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "getDurableSubscriptionConsumerDispatcher", subState);
  
          ConsumerDispatcher consumerDispatcher = null;
  
          // NOTE: there are two unsynchronized calls to this method from SIMPSubscriptionAssert
          // The more common call from createDurableSubscription already holds the lock
          // here in which case the extra synchronized is minor overhead.
  
          synchronized (_consumerDispatchersDurable)
          {
              consumerDispatcher =
                              (ConsumerDispatcher) _consumerDispatchersDurable.get(
                                              subState.getSubscriberID());
          }
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(
                         tc,
                         "getDurableSubscriptionConsumerDispatcher",
                         consumerDispatcher);
  
          return consumerDispatcher;
      }
docs: /*
  (non-Javadoc)
  
  @see com.ibm.ws.sib.processor.impl.interfaces.DestinationHandler#getDurableSubscriptionConsumerDispatcher(com.ibm.ws.sib.processor.impl.ConsumerDispatcherState)