import static org.mockito.Matchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.never;
-import static org.mockito.Mockito.times;
import static org.mockito.Mockito.reset;
import static org.mockito.Mockito.timeout;
+import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify;
import static org.opendaylight.controller.cluster.datastore.entityownership.EntityOwnersModel.ENTITY_OWNERS_PATH;
import static org.opendaylight.controller.cluster.datastore.entityownership.EntityOwnersModel.candidatePath;
return newShardProps(Collections.<String,String>emptyMap());
}
- private Props newShardProps(EntityOwnerSelectionStrategyConfig strategyConfig) {
- return newShardProps(newShardId(LOCAL_MEMBER_NAME), Collections.<String,String>emptyMap(),
- LOCAL_MEMBER_NAME, strategyConfig);
- }
-
private Props newShardProps(EntityOwnerSelectionStrategyConfig strategyConfig, Map<String, String> peers) {
return newShardProps(newShardId(LOCAL_MEMBER_NAME), peers, LOCAL_MEMBER_NAME, strategyConfig);
}
-
private Props newShardProps(Map<String,String> peers) {
return newShardProps(newShardId(LOCAL_MEMBER_NAME), peers, LOCAL_MEMBER_NAME, EntityOwnerSelectionStrategyConfig.newBuilder().build());
}
}
@Override
- public void onReceiveCommand(Object message) throws Exception {
+ public void handleCommand(Object message) {
if(!(message instanceof ElectionTimeout)) {
- super.onReceiveCommand(message);
+ super.handleCommand(message);
}
}
-
-
}
public static class MockFollower extends UntypedActor {