docs: public void reconstituteAnycastRMEPhaseOne() 
      throws MessageStoreException, SIResourceException
    {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.entry(tc, "reconstituteAnycastRMEPhaseOne");
      
      NonLockingCursor cursor =
      _baseDestinationHandler.newNonLockingItemStreamCursor(
          new ClassEqualsFilter(AIContainerItemStream.class));
        
      AIContainerItemStream aiTempItemStream = null;
      do
      {
        aiTempItemStream = (AIContainerItemStream) cursor.next();
        if (aiTempItemStream != null)
        {
          // NOTE: since this destination is PtoP it should NOT be
          // possible to end up recovering an aistream used for durable.
          // Still, bugs happen, so here's a sanity check
          if (aiTempItemStream.getDurablePseudoDestID() != null)
          {
            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
              SibTr.exit(tc, "reconstituteAnycastRME", "SIResourceException");
            throw new SIErrorException(
            nls.getFormattedMessage(
              "INTERNAL_MESSAGING_ERROR_CWSIP0003",
              new Object[] {
                "com.ibm.ws.sib.processor.impl.destination.AbstractRemoteSupport.reconstituteAnycastRMEPhaseOne",
                "1:230:1.25",
                null },
              null));
          }
          
          String key = SIMPUtils.getRemoteGetKey(aiTempItemStream.getDmeId(), aiTempItemStream.getGatheringTargetDestUuid());
          _aiContainerItemStreams.put(key, aiTempItemStream);
        }
      }
      while (aiTempItemStream != null);
      
      cursor.finished();
      
      cursor =
      _baseDestinationHandler.newNonLockingItemStreamCursor(
          new ClassEqualsFilter(PtoPReceiveMsgsItemStream.class));
      
      PtoPReceiveMsgsItemStream rcdTempItemStream = (PtoPReceiveMsgsItemStream)cursor.next();
      if (rcdTempItemStream != null && !rcdTempItemStream.isRestoring())
      {
        try
        {
          LocalTransaction tran =
          _baseDestinationHandler.getTransactionManager().createLocalTransaction(true);
          
          do
          {
            rcdTempItemStream.reconstitute(_baseDestinationHandler);
            // not really reallocate, just remove all items
            rcdTempItemStream.reallocateMsgs();
            rcdTempItemStream.remove((Transaction) tran, AbstractItem.NO_LOCK_ID);
            
            rcdTempItemStream = (PtoPReceiveMsgsItemStream)cursor.next();
          }
          while (rcdTempItemStream != null);
  
          tran.commit();
        }
        catch(Exception e)
        {
          FFDCFilter.processException(
            e,
            "com.ibm.ws.sib.processor.impl.destination.AbstractRemoteSupport.reconstituteAnycastRMEPhaseOne",
            "1:273:1.25",
            this);
                        
          SibTr.exception(tc, e);
          if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(
              tc,
              "reconstituteAnycastRMEPhaseOne",
              "SIResourceException");
          throw new SIResourceException(e);
        }
      }
      
      cursor.finished();
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(tc, "reconstituteAnycastRMEPhaseOne");
    }