docs: public final void writtenStartedFlush(AOStream stream, Item startedFlushItem)
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, "writtenStartedFlush");
  
      String key = 
        SIMPUtils.getRemoteGetKey(stream.getRemoteMEUuid(), stream.getGatheringTargetDestUuid());
      StreamInfo sinfo = streamTable.get(key);
      if ((sinfo != null) && sinfo.streamId.equals(stream.streamId))
      {
        synchronized (sinfo)
        {
          sinfo.item = (AOStartedFlushItem) startedFlushItem;
        }
      }
      else
      {
        // 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:2858:1.89.4.1" },
            null));
  
        // FFDC
        FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.impl.AnycastOutputHandler.writtenStartedFlush",
          "1:2865: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:2872:1.89.4.1" });
  
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
          SibTr.exit(tc, "writtenStartedFlush", e);
        throw e;
      }
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "writtenStartedFlush");
    }