private OpenReplicatorManagerMBean createInternalService(String serviceName) throws ReplicatorException {
  logger.info("Starting replication service: name=" + serviceName);
  try {
    OpenReplicatorManager orm=new OpenReplicatorManager(serviceName);
    orm.setRmiHost(managerRMIHost);
    orm.setRmiPort(managerRMIPort);
    orm.setHostTimeZone(hostTimeZone);
    orm.setReplicatorTimeZone(replicatorTimeZone);
    orm.advertiseInternal();
    orm.setSecurityInfo(this.securityInfo);
    return (OpenReplicatorManagerMBean)orm;
  }
 catch (  Exception e) {
    throw new ReplicatorException(String.format("Unable to instantiate replication service '%s'",serviceName),e);
  }
}

private OpenReplicatorManagerMBean createInternalService ( String serviceName ) throws ReplicatorException { logger . info ( "Starting replication service: name=" + serviceName ) ; try { OpenReplicatorManager orm = new OpenReplicatorManager ( serviceName ) ; orm . setRmiHost ( managerRMIHost ) ; orm . setRmiPort ( managerRMIPort ) ; orm . setHostTimeZone ( hostTimeZone ) ; orm . setReplicatorTimeZone ( replicatorTimeZone ) ; orm . advertiseInternal ( ) ; orm . setSecurityInfo ( this . securityInfo ) ; return ( OpenReplicatorManagerMBean ) orm ; } catch ( Exception e ) { throw new ReplicatorException ( String . format ( "Unable to instantiate replication service '%s'" , serviceName ) , e ) ; } }
creates a replication service that will run as a thread internal to the replicationservicemanager .
