@Test
public void testEntityOwnershipShardCreated() throws Exception {
- DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore);
+ DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore, EntityOwnerSelectionStrategyConfig.newBuilder().build());
service.start();
Future<ActorRef> future = dataStore.getActorContext().findLocalShardAsync(
@Test
public void testRegisterCandidate() throws Exception {
final TestShardPropsCreator shardPropsCreator = new TestShardPropsCreator();
- DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore) {
+ DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore, EntityOwnerSelectionStrategyConfig.newBuilder().build()) {
@Override
protected EntityOwnershipShardPropsCreator newShardPropsCreator() {
return shardPropsCreator;
@Test
public void testCloseCandidateRegistration() throws Exception {
final TestShardPropsCreator shardPropsCreator = new TestShardPropsCreator();
- DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore) {
+ DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore, EntityOwnerSelectionStrategyConfig.newBuilder().build()) {
@Override
protected EntityOwnershipShardPropsCreator newShardPropsCreator() {
return shardPropsCreator;
@Test
public void testListenerRegistration() {
final TestShardPropsCreator shardPropsCreator = new TestShardPropsCreator();
- DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore) {
+ DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore, EntityOwnerSelectionStrategyConfig.newBuilder().build()) {
@Override
protected EntityOwnershipShardPropsCreator newShardPropsCreator() {
return shardPropsCreator;
@Test
public void testGetOwnershipState() throws Exception {
final TestShardPropsCreator shardPropsCreator = new TestShardPropsCreator();
- DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore) {
+ DistributedEntityOwnershipService service = new DistributedEntityOwnershipService(dataStore, EntityOwnerSelectionStrategyConfig.newBuilder().build()) {
@Override
protected EntityOwnershipShardPropsCreator newShardPropsCreator() {
return shardPropsCreator;