docs: @Override
      public void deliverExpressMessage(MessageItem msgItem,
                                        ExpressTargetStream expressTargetStream) throws SIResourceException, SIIncorrectCallException
      {
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.entry(tc, "deliverExpressMessage", new Object[] { msgItem });
  
          //Create transaction
          LocalTransaction siTran = _txManager.createLocalTransaction(false);
  
          try
          {
              // msg is currently the last message in the list
              // get it's tick value for use in sending Acks and updating stream
              long endTick = msgItem.getMessage().getGuaranteedValueValueTick();
  
              msgItem.setTransacted(true);
  
              //get the matching results back from the message
              MessageProcessorSearchResults searchResults = msgItem.getSearchResults();
  
              // Store it
              boolean stored = deliverToConsumerDispatchers(searchResults, msgItem, siTran, false);
  
              // Update the completedPrefix on the stream
              // This will put all ticks before this point into Completed state
              expressTargetStream.setCompletedPrefix(endTick);
  
              if (stored)
                  siTran.commit();
              else
                  siTran.rollback();
  
          } 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.PubSubInputHandler.deliverExpressMessage",
                                          "1:2908:1.329.1.1",
                                          this);
  
              if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              {
                  SibTr.exception(tc, e);
                  SibTr.exit(tc, "deliverExpressMessage", e);
              }
  
              throw e;
          } catch (SIIncorrectCallException e)
          {
              // No FFDC code needed
              handleRollback(siTran);
  
              if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                  SibTr.exit(tc, "deliverExpressMessage", e);
  
              throw e;
          }
  
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
              SibTr.exit(tc, "deliverExpressMessage");
      }