docs: public void reconstituteAnycastRMEPhaseTwo(int startMode,
                                       DestinationDefinition definition) 
      throws MessageStoreException, SIResourceException
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, 
                    "reconstituteAnycastRMEPhaseTwo",
                    new Object[] { 
                    Integer.valueOf(startMode),
                    definition});
      
      // We need to reconstiture the AnycastInputHandlers/RCDs so that all parts of the destination
      // are ready for various reasons:
      //   - The inactivity timer is initiated to allow automatic cleanup if a new consumer doesn't attach
      //   - Incoming control messages for existing anycast streams are correctly processed
      //   - The asynchDeletionThread sees all of the destination, so it can correctly clean it up if it
      //     is deleted
      
      boolean flush = false;
      // We flush the streams if in START_FLUSH mode, but not if we're in recovery mode, because we won't
      // be able to send any messages to the DME
      if(   ((startMode & JsConstants.ME_START_FLUSH ) == JsConstants.ME_START_FLUSH )
         && ((startMode & JsConstants.ME_START_RECOVERY ) == 0 ) )
        flush = true;
      
      synchronized (_anycastInputHandlers)
      {
        for(Iterator i = _aiContainerItemStreams.values().iterator(); i.hasNext();)
        {
          // If the AIH hasn't been reconstituted yet (can be kicked off from inside
          // the local reconstitution when it chooses a ConsumerManager) we do it now.
          AIContainerItemStream stream = (AIContainerItemStream) i.next();
          String key = SIMPUtils.getRemoteGetKey(stream.getDmeId(), stream.getGatheringTargetDestUuid());
          AnycastInputHandler aih = _anycastInputHandlers.get(key);
         
          if(aih == null)
          {
            aih = createAIHandRCD(stream.getDmeId(),
                stream.getGatheringTargetDestUuid(),
                definition, 
                flush);
            _anycastInputHandlers.put(key, aih);
          }
        }
      }
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "reconstituteAnycastRMEPhaseTwo");
    }