private final Set<String> shardReplicaOperationsInProgress = new HashSet<>();
- private final String id;
+ private final String persistenceId;
/**
*/
this.primaryShardInfoCache = builder.primaryShardInfoCache;
this.restoreFromSnapshot = builder.restoreFromSnapshot;
- id = "shard-manager-" + type;
+ String possiblePersistenceId = datastoreContextFactory.getBaseDatastoreContext().getShardManagerPersistenceId();
+ persistenceId = possiblePersistenceId != null ? possiblePersistenceId : "shard-manager-" + type;
peerAddressResolver = new ShardPeerAddressResolver(type, cluster.getCurrentMemberName());
@Override
public String persistenceId() {
- return id;
+ return persistenceId;
}
@VisibleForTesting