- public java.lang.AutoCloseable createInstance() {
-
- ConfigProperties props = getConfigProperties();
- if(props == null) {
- props = new ConfigProperties();
- }
-
- DatastoreContext datastoreContext = DatastoreContext.newBuilder()
- .dataStoreMXBeanType("DistributedConfigDatastore")
- .dataStoreProperties(InMemoryDOMDataStoreConfigProperties.create(
- props.getMaxShardDataChangeExecutorPoolSize().getValue().intValue(),
- props.getMaxShardDataChangeExecutorQueueSize().getValue().intValue(),
- props.getMaxShardDataChangeListenerQueueSize().getValue().intValue(),
- props.getMaxShardDataStoreExecutorQueueSize().getValue().intValue()))
- .shardTransactionIdleTimeout(Duration.create(
- props.getShardTransactionIdleTimeoutInMinutes().getValue(), TimeUnit.MINUTES))
- .operationTimeoutInSeconds(props.getOperationTimeoutInSeconds().getValue())
- .shardJournalRecoveryLogBatchSize(props.getShardJournalRecoveryLogBatchSize().
- getValue().intValue())
- .shardSnapshotBatchCount(props.getShardSnapshotBatchCount().getValue().intValue())
- .shardHeartbeatIntervalInMillis(props.getShardHearbeatIntervalInMillis().getValue())
- .shardTransactionCommitTimeoutInSeconds(
- props.getShardTransactionCommitTimeoutInSeconds().getValue().intValue())
- .shardTransactionCommitQueueCapacity(
- props.getShardTransactionCommitQueueCapacity().getValue().intValue())
- .build();