* configuration or operational
*/
private ShardManager(String type){
- ActorRef actor = getContext().actorOf(Shard.props(Shard.DEFAULT_NAME + "-" + type));
+ ActorRef actor = getContext().actorOf(Shard.props("shard-" + Shard.DEFAULT_NAME + "-" + type), "shard-" + Shard.DEFAULT_NAME + "-" + type);
defaultShardPath = actor.path();
}
getSender().tell(new PrimaryNotFound(shardName), getSelf());
}
} else if(message instanceof UpdateSchemaContext){
- // FIXME : Notify all local shards of a context change
+ // FIXME : Notify all local shards of a schemaContext change
getContext().system().actorSelection(defaultShardPath).forward(message, getContext());
}
}