@Override
public void onDatastoreContextUpdated(DatastoreContextFactory contextFactory) {
- LOG.info("DatastoreContext updated for data store {}", actorContext.getDataStoreType());
+ LOG.info("DatastoreContext updated for data store {}", actorContext.getDataStoreName());
actorContext.setDatastoreContext(contextFactory);
datastoreConfigMXBean.setContext(contextFactory.getBaseDatastoreContext());
}
}
- private ActorRef createShardManager(ActorSystem actorSystem, ShardManager.Builder builder, String shardDispatcher,
- String shardManagerId){
+ private static ActorRef createShardManager(ActorSystem actorSystem, ShardManager.Builder builder,
+ String shardDispatcher, String shardManagerId) {
Exception lastException = null;
for(int i=0;i<100;i++) {