docs: public void execute(TransactionCommon t) throws Throwable
      {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
          SibTr.entry(tc, "execute", t);
  
        _aiStream.removeCompletedPrefix(
          t,
          _messageProcessor.getMessageStore().getUniqueLockID(AbstractItem.STORE_NEVER));
        synchronized (_persistentStreamState)
        {
          if (_streamStateRemoveNeedsToWait)
          {
            _persistentStreamState.wait();
          }
  
          long lockID = _messageProcessor.getMessageStore().getUniqueLockID(AbstractItem.STORE_NEVER);
          _persistentStreamState.lockItemIfAvailable(lockID);
          Transaction msTran = _messageProcessor.resolveAndEnlistMsgStoreTransaction(t);
          _persistentStreamState.remove(msTran, lockID);
        }
  
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
          SibTr.exit(tc, "execute");
      }