.shardElectionTimeoutFactor(props.getShardElectionTimeoutFactor().getValue())
.transactionCreationInitialRateLimit(props.getTransactionCreationInitialRateLimit().getValue())
.shardBatchedModificationCount(props.getShardBatchedModificationCount().getValue().intValue())
+ .shardCommitQueueExpiryTimeoutInSeconds(
+ props.getShardCommitQueueExpiryTimeoutInSeconds().getValue().intValue())
+ .transactionDebugContextEnabled(props.getTransactionDebugContextEnabled())
+ .customRaftPolicyImplementation(props.getCustomRaftPolicyImplementation())
+ .shardSnapshotChunkSize(props.getShardSnapshotChunkSize().getValue().intValue())
.build();
return DistributedDataStoreFactory.createInstance(getConfigSchemaServiceDependency(),
- datastoreContext, bundleContext);
+ datastoreContext, getConfigActorSystemProviderDependency().getActorSystem(), bundleContext);
}
public void setBundleContext(BundleContext bundleContext) {