private void resetRedo(String name,TungstenProperties serviceProps,Map<String,String> progress){
  String clusterHome;
  try {
    clusterHome=ClusterConfiguration.getClusterHome();
  }
 catch (  ConfigurationException e) {
    logger.error("Unable to locate cluster-home directory; ensure replicator is properly installed",e);
    return;
  }
  String vmrrControlScriptName="bin/vmrrd_" + name;
  File vmrrControlScript=new File(clusterHome,vmrrControlScriptName);
  if (vmrrControlScript.canExecute()) {
    logger.info("Found vmrr control script, trying to reset Oracle redo reader: " + vmrrControlScript.getAbsolutePath());
    try {
      RedoReaderManager vmrrMgr=new RedoReaderManager();
      vmrrMgr.setVmrrControlScript(vmrrControlScript.getAbsolutePath());
      vmrrMgr.setReplicateApplyName(name);
      vmrrMgr.initialize();
      vmrrMgr.reset("NOW");
    }
 catch (    ReplicatorException e) {
      logger.error("Unable to configure redo reader: " + e.getMessage(),e);
    }
  }
}

private void resetRedo ( String name , TungstenProperties serviceProps , Map < String , String > progress ) { String clusterHome ; try { clusterHome = ClusterConfiguration . getClusterHome ( ) ; } catch ( ConfigurationException e ) { logger . error ( "Unable to locate cluster-home directory; ensure replicator is properly installed" , e ) ; return ; } String vmrrControlScriptName = "bin/vmrrd_" + name ; File vmrrControlScript = new File ( clusterHome , vmrrControlScriptName ) ; if ( vmrrControlScript . canExecute ( ) ) { logger . info ( "Found vmrr control script, trying to reset Oracle redo reader: " + vmrrControlScript . getAbsolutePath ( ) ) ; try { RedoReaderManager vmrrMgr = new RedoReaderManager ( ) ; vmrrMgr . setVmrrControlScript ( vmrrControlScript . getAbsolutePath ( ) ) ; vmrrMgr . setReplicateApplyName ( name ) ; vmrrMgr . initialize ( ) ; vmrrMgr . reset ( "NOW" ) ; } catch ( ReplicatorException e ) { logger . error ( "Unable to configure redo reader: " + e . getMessage ( ) , e ) ; } } }
resets the redo reader if it exists . this only exists for oracle replication .
