private void startReplicationService(TungstenProperties replProps) throws ReplicatorException {
  String serviceName=replProps.getString(ReplicatorConf.SERVICE_NAME);
  String serviceType=replProps.getString(ReplicatorConf.SERVICE_TYPE);
  boolean isDetached=replProps.getBoolean(ReplicatorConf.DETACHED);
  OpenReplicatorManagerMBean orm=null;
  try {
    if (isDetached) {
      throw new ReplicatorException("Creating of detached service is no longer supported");
    }
 else {
      orm=createInternalService(serviceName);
    }
    replicators.put(serviceName,orm);
    orm.start(replProps.getBoolean(ReplicatorConf.FORCE_OFFLINE));
    int listenPort=orm.getMasterListenPort();
    if (listenPort > masterListenPortMax)     masterListenPortMax=listenPort;
    logger.info(String.format("%s/%s replication service '%s' started successfully",(isDetached ? "detached" : "internal"),serviceType,serviceName));
  }
 catch (  Exception e) {
    logger.error(String.format("Unable to start replication service '%s'",serviceName),e);
  }
}

private void startReplicationService ( TungstenProperties replProps ) throws ReplicatorException { String serviceName = replProps . getString ( ReplicatorConf . SERVICE_NAME ) ; String serviceType = replProps . getString ( ReplicatorConf . SERVICE_TYPE ) ; boolean isDetached = replProps . getBoolean ( ReplicatorConf . DETACHED ) ; OpenReplicatorManagerMBean orm = null ; try { if ( isDetached ) { throw new ReplicatorException ( "Creating of detached service is no longer supported" ) ; } else { orm = createInternalService ( serviceName ) ; } replicators . put ( serviceName , orm ) ; orm . start ( replProps . getBoolean ( ReplicatorConf . FORCE_OFFLINE ) ) ; int listenPort = orm . getMasterListenPort ( ) ; if ( listenPort > masterListenPortMax ) masterListenPortMax = listenPort ; logger . info ( String . format ( "%s/%s replication service '%s' started successfully" , ( isDetached ? "detached" : "internal" ) , serviceType , serviceName ) ) ; } catch ( Exception e ) { logger . error ( String . format ( "Unable to start replication service '%s'" , serviceName ) , e ) ; } }
utility routine to start a replication service . it will be started either as an internal thread or as a detached process , depending on it ' s configuration
