本文整理了Java中com.hazelcast.config.Config.setCRDTReplicationConfig()
方法的一些代码示例,展示了Config.setCRDTReplicationConfig()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Config.setCRDTReplicationConfig()
方法的具体详情如下:
包路径:com.hazelcast.config.Config
类名称:Config
方法名:setCRDTReplicationConfig
[英]Sets the replication configuration for com.hazelcast.crdt.CRDTimplementations.
[中]设置com的复制配置。黑泽尔卡斯特。crdt。CRDT实现。
代码示例来源:origin: hazelcast/hazelcast-jet
private void handleCRDTReplication(Node root) {
final CRDTReplicationConfig replicationConfig = new CRDTReplicationConfig();
final String replicationPeriodMillisName = "replication-period-millis";
final String maxConcurrentReplicationTargetsName = "max-concurrent-replication-targets";
for (Node n : childElements(root)) {
final String name = cleanNodeName(n);
if (replicationPeriodMillisName.equals(name)) {
replicationConfig.setReplicationPeriodMillis(
getIntegerValue(replicationPeriodMillisName, getTextContent(n)));
} else if (maxConcurrentReplicationTargetsName.equals(name)) {
replicationConfig.setMaxConcurrentReplicationTargets(
getIntegerValue(maxConcurrentReplicationTargetsName, getTextContent(n)));
}
}
this.config.setCRDTReplicationConfig(replicationConfig);
}
代码示例来源:origin: com.hazelcast/hazelcast-all
private void handleCRDTReplication(Node root) {
final CRDTReplicationConfig replicationConfig = new CRDTReplicationConfig();
final String replicationPeriodMillisName = "replication-period-millis";
final String maxConcurrentReplicationTargetsName = "max-concurrent-replication-targets";
for (Node n : childElements(root)) {
final String name = cleanNodeName(n);
if (replicationPeriodMillisName.equals(name)) {
replicationConfig.setReplicationPeriodMillis(
getIntegerValue(replicationPeriodMillisName, getTextContent(n)));
} else if (maxConcurrentReplicationTargetsName.equals(name)) {
replicationConfig.setMaxConcurrentReplicationTargets(
getIntegerValue(maxConcurrentReplicationTargetsName, getTextContent(n)));
}
}
this.config.setCRDTReplicationConfig(replicationConfig);
}
内容来源于网络,如有侵权,请联系作者删除!