docs: @Override
      public void deliverExpressMessage(MessageItem msgItem,
                                        ExpressTargetStream expressTargetStream)
  
                      throws SIIncorrectCallException, SIResourceException
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "deliverExpressMessage", new Object[] { msgItem });
  
          //Create transaction
          LocalTransaction siTran = _txManager.createLocalTransaction(false);
  
          try
          {
              long endTick = msgItem.getMessage().getGuaranteedValueValueTick();
  
              JsDestinationAddress routingDestinationAddr =
                              msgItem.getMessage().getRoutingDestination();
              if (routingDestinationAddr != null)
              {
                  DestinationHandler routingDestination = null;
                  try
                  {
                      routingDestination =
                                      _destinationManager.getDestination(routingDestinationAddr, false, true);
  
                      if (_isLink)
                      {
                          LinkHandler link = (LinkHandler) _destination;
  
                          // If this is coming in off a link then use the link's configuration
                          // to determine if any local message points should be preferred
                          msgItem.setPreferLocal(link.preferLocalTargetQueuePoint());
  
                          String linkInboundUserid = ((LinkHandler) _destination).getInboundUserid();
                          if (linkInboundUserid != null)
                          {
                              if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
                                  SibTr.debug(tc, "Set link inbound userid: " + linkInboundUserid + ", into message");
                              // Call SIB.security (ultimately) to set inbounduserid into msg
                              _messageProcessor.getAccessChecker().setSecurityIDInMessage(
                                                                                          linkInboundUserid,
                                                                                          msgItem.getMessage());
                          }
                      }
                      // If it's come from another ME in the bus then they're sending it
                      // to this message point because they want to so we prefer the local one.
                      // This allows the mesasge to be re-routed if absolutely necessary.
                      else
                          msgItem.setPreferLocal(true);
  
                      // Call the handler to deal with the message - passing null as the producer
                      // session id.
                      ProducerInputHandler inputHandler =
                                      (ProducerInputHandler) routingDestination.getInputHandler();
  
                      inputHandler.handleMessage(msgItem,
                                                 siTran,
                                                 _messageProcessor.getMessagingEngineUuid());
  
                  } catch (SIException e)
                  {
                      // No FFDC code needed
  
                      if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
                      {
                          SibTr.exception(tc, e);
                          SibTr.debug(tc, "Discarding the express message as it could not be from the targetStreamManager");
                      }
                  }
              }
              else
              {
                  ConsumerDispatcher consumerDispatcher;
  
                  consumerDispatcher = (ConsumerDispatcher) _destination.getLocalPtoPConsumerManager();
                  consumerDispatcher.put(msgItem, siTran, null, false);
              }
  
              // Update the completedPrefix on the stream
              // This will put all ticks before this point into Completed state
              expressTargetStream.setCompletedPrefix(endTick);
  
              siTran.commit();
          } catch (SIIncorrectCallException e)
          {
              // No FFDC code needed
              handleRollback(siTran);
  
              if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                  SibTr.exit(tc, "deliverExpressMessage", e);
  
              throw e;
          } catch (SIResourceException e)
          {
              // No FFDC code needed
              handleRollback(siTran);
  
              if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                  SibTr.exit(tc, "deliverExpressMessage", e);
  
              throw e;
          } catch (RuntimeException e)
          {
              // FFDC
              FFDCFilter.processException(
                                          e,
                                          "com.ibm.ws.sib.processor.impl.PtoPInputHandler.deliverExpressMessage",
                                          "1:2840:1.323",
                                          this);
  
              handleRollback(siTran);
  
              if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              {
                  SibTr.exception(tc, e);
                  SibTr.exit(tc, "deliverExpressMessage", e);
              }
  
              throw e;
          }
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "deliverExpressMessage");
      }