code: public void committed()
      {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
          SibTr.entry(tc, "committed");
  
        try
        {
          _aiStream =
            new AIStream(
              streamId,
              itemStream,
              AnycastInputHandler.this,
              _msUpdateThread,
              latestTick,
              completedPrefixItem,
              false,
              _messageProcessor);
        }
        catch (Exception e)
        {
          // this cannot happen since new AIStream only throws if there is an existing stream
          FFDCFilter.processException(
            e,
            "com.ibm.ws.sib.processor.impl.AnycastInputHandler.CreatePersistentStream.committed",
            "1:4735:1.219.1.1",
            this);
  
          SibTr.exception(tc, e);
        }
  
        _persistentStreamState = itemStream;
  
        // 243428; now that we have a stream, make sure that the timers are started
        start();
  
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
          SibTr.exit(tc, "committed");
      }
docs: Called while 'this' and _streamStatus is held