docs: public final Item writeStartedFlush(TransactionCommon t, AOStream stream) throws Exception
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, "writeStartedFlush");
  
      String key = 
        SIMPUtils.getRemoteGetKey(stream.getRemoteMEUuid(), stream.getGatheringTargetDestUuid());
      StreamInfo sinfo = streamTable.get(key);
      if ((sinfo != null) && sinfo.streamId.equals(stream.streamId))
      {
        AOStartedFlushItem item = new AOStartedFlushItem(key, stream.streamId);
        Transaction msTran = mp.resolveAndEnlistMsgStoreTransaction(t);
        this.containerItemStream.addItem(item, msTran);
  
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
          SibTr.exit(tc, "writeStartedFlush", item);
  
        return item;
      }
  
      // this should not occur
      // log error and throw exception
      SIErrorException e = new SIErrorException(
        nls.getFormattedMessage(
          "INTERNAL_MESSAGING_ERROR_CWSIP0001",
          new Object[] { "com.ibm.ws.sib.processor.impl.AnycastOutputHandler", "1:2810:1.89.4.1" },
          null));
  
      // FFDC
      FFDCFilter.processException(
        e,
        "com.ibm.ws.sib.processor.impl.AnycastOutputHandler.writeStartedFlush",
        "1:2817:1.89.4.1",
        this);
  
      SibTr.exception(tc, e);
      SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0001",
      new Object[] { "com.ibm.ws.sib.processor.impl.AnycastOutputHandler", "1:2822:1.89.4.1" });
  
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "writeStartedFlush", e);
      throw e;
    }