本文整理了Java中com.hazelcast.config.Config.getCRDTReplicationConfig()方法的一些代码示例，展示了Config.getCRDTReplicationConfig()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Config.getCRDTReplicationConfig()方法的具体详情如下：
包路径：com.hazelcast.config.Config
类名称：Config
方法名：getCRDTReplicationConfig

Config.getCRDTReplicationConfig介绍

暂无

代码示例

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public CRDTReplicationConfig getCRDTReplicationConfig() {
  return staticConfig.getCRDTReplicationConfig();
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public CRDTReplicationConfig getCRDTReplicationConfig() {
  return staticConfig.getCRDTReplicationConfig();
}

代码示例来源：origin: hazelcast/hazelcast-jet

private static void crdtReplicationXmlGenerator(XmlGenerator gen, Config config) {
  CRDTReplicationConfig replicationConfig = config.getCRDTReplicationConfig();
  gen.open("crdt-replication");
  if (replicationConfig != null) {
    gen.node("replication-period-millis", replicationConfig.getReplicationPeriodMillis())
        .node("max-concurrent-replication-targets", replicationConfig.getMaxConcurrentReplicationTargets());
  }
  gen.close();
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private static void crdtReplicationXmlGenerator(XmlGenerator gen, Config config) {
  CRDTReplicationConfig replicationConfig = config.getCRDTReplicationConfig();
  gen.open("crdt-replication");
  if (replicationConfig != null) {
    gen.node("replication-period-millis", replicationConfig.getReplicationPeriodMillis())
        .node("max-concurrent-replication-targets", replicationConfig.getMaxConcurrentReplicationTargets());
  }
  gen.close();
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public void init(NodeEngine nodeEngine, Properties properties) {
  final CRDTReplicationConfig replicationConfig = nodeEngine.getConfig().getCRDTReplicationConfig();
  final int replicationPeriod = replicationConfig != null
      ? replicationConfig.getReplicationPeriodMillis()
      : CRDTReplicationConfig.DEFAULT_REPLICATION_PERIOD_MILLIS;
  this.nodeEngine = nodeEngine;
  this.logger = nodeEngine.getLogger(getClass());
  this.replicationVectorClocks = new ReplicatedVectorClocks();
  int maxTargets = replicationConfig != null
      ? replicationConfig.getMaxConcurrentReplicationTargets()
      : CRDTReplicationConfig.DEFAULT_MAX_CONCURRENT_REPLICATION_TARGETS;
  this.replicationTask = nodeEngine.getExecutionService().scheduleWithRepetition(
      CRDT_REPLICATION_MIGRATION_EXECUTOR, new CRDTReplicationTask(nodeEngine, maxTargets, this),
      replicationPeriod, replicationPeriod, TimeUnit.MILLISECONDS);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public void init(NodeEngine nodeEngine, Properties properties) {
  final CRDTReplicationConfig replicationConfig = nodeEngine.getConfig().getCRDTReplicationConfig();
  final int replicationPeriod = replicationConfig != null
      ? replicationConfig.getReplicationPeriodMillis()
      : CRDTReplicationConfig.DEFAULT_REPLICATION_PERIOD_MILLIS;
  this.nodeEngine = nodeEngine;
  this.logger = nodeEngine.getLogger(getClass());
  this.replicationVectorClocks = new ReplicatedVectorClocks();
  int maxTargets = replicationConfig != null
      ? replicationConfig.getMaxConcurrentReplicationTargets()
      : CRDTReplicationConfig.DEFAULT_MAX_CONCURRENT_REPLICATION_TARGETS;
  this.replicationTask = nodeEngine.getExecutionService().scheduleWithRepetition(
      CRDT_REPLICATION_MIGRATION_EXECUTOR, new CRDTReplicationTask(nodeEngine, maxTargets, this),
      replicationPeriod, replicationPeriod, TimeUnit.MILLISECONDS);
}