this.tcpSelectorTimeout,
IDataSenderFactory.SYNC_MODE.equals(replicationMode) ||
IDataSenderFactory.POOLED_SYNC_MODE.equals(replicationMode));
mReplicationListener.setName("Cluster-ReplicationListener");
mReplicationListener.setDaemon(true);
mReplicationListener.start();
}
mReplicationTransmitter = new ReplicationTransmitter(new IDataSender[0]);
mReplicationTransmitter.start();