code: public void removeProtocolItems(TransactionCommon transaction)
      throws SIResourceException
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, "removeProtocolItems", transaction );
  
      Transaction msTran = _messageProcessor.resolveAndEnlistMsgStoreTransaction(transaction);
      
      try
      {
        //Clean up destination stream state
        if (_targetProtocolItemStream != null)
        {
          _targetProtocolItemStream.removeAll(msTran);
        }
       
        if (_sourceProtocolItemStream != null)
        { 
          _sourceProtocolItemStream.removeAll(msTran);
        }
        
      }
      catch (MessageStoreException e)
      {
        // FFDC
        FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.impl.destination.AbstractRemoteSupport.removeProtocolItems",
          "1:636:1.25",
          this);
  
        SibTr.exception(tc, e);
  
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
          SibTr.exit(tc, "removeProtocolItems", e);
  
        throw new SIResourceException(e);
      }
  
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "removeProtocolItems");
    }
docs: Method removeProtocolItems.
  <p>This removes protocol items from ProtocolItemStream.
  @param transaction
  @throws SIResourceException