public boolean recreateRSetStep(URI rpSystemId,List<URI> volumeIds,Map<String,RecreateReplicationSetRequestParams> rsetParams,String token) throws InternalException {
  List<String> replicationSetNames=new ArrayList<String>();
  try {
    ProtectionSystem rpSystem=_dbClient.queryObject(ProtectionSystem.class,rpSystemId);
    for (    URI volumeId : volumeIds) {
      Volume volume=_dbClient.queryObject(Volume.class,volumeId);
      replicationSetNames.add(volume.getRSetName());
    }
    RecoverPointClient rp=RPHelper.getRecoverPointClient(rpSystem);
    _log.info("Sleeping for 15 seconds before rescanning bus to account for latencies.");
    try {
      Thread.sleep(15000);
    }
 catch (    InterruptedException e) {
      _log.warn("Thread sleep interrupted.  Allowing to continue without sleep");
    }
    rp.recreateReplicationSets(rsetParams);
    WorkflowStepCompleter.stepSucceded(token);
  }
 catch (  Exception e) {
    _log.error(String.format("recreateRSetStep Failed - Replication Set(s): %s",replicationSetNames.toString()));
    return stepFailed(token,e,"recreateRSetStep");
  }
  return true;
}

public boolean recreateRSetStep ( URI rpSystemId , List < URI > volumeIds , Map < String , RecreateReplicationSetRequestParams > rsetParams , String token ) throws InternalException { List < String > replicationSetNames = new ArrayList < String > ( ) ; try { ProtectionSystem rpSystem = _dbClient . queryObject ( ProtectionSystem . class , rpSystemId ) ; for ( URI volumeId : volumeIds ) { Volume volume = _dbClient . queryObject ( Volume . class , volumeId ) ; replicationSetNames . add ( volume . getRSetName ( ) ) ; } RecoverPointClient rp = RPHelper . getRecoverPointClient ( rpSystem ) ; _log . info ( "Sleeping for 15 seconds before rescanning bus to account for latencies." ) ; try { Thread . sleep ( 15000 ) ; } catch ( InterruptedException e ) { _log . warn ( "Thread sleep interrupted.  Allowing to continue without sleep" ) ; } rp . recreateReplicationSets ( rsetParams ) ; WorkflowStepCompleter . stepSucceded ( token ) ; } catch ( Exception e ) { _log . error ( String . format ( "recreateRSetStep Failed - Replication Set(s): %s" , replicationSetNames . toString ( ) ) ) ; return stepFailed ( token , e , "recreateRSetStep" ) ; } return true ; }
recreate the replication set
