private void onRemoveServerReply(ActorRef originalSender, ShardIdentifier shardId, RemoveServerReply replyMsg,
String leaderPath) {
- shardReplicaOperationsInProgress.remove(shardId);
+ shardReplicaOperationsInProgress.remove(shardId.getShardName());
LOG.debug ("{}: Received {} for shard {}", persistenceId(), replyMsg, shardId.getShardName());
findPrimary(shardName, new AutoFindPrimaryFailureResponseHandler(getSender(), shardName, persistenceId(), getSelf()) {
@Override
public void onRemotePrimaryShardFound(RemotePrimaryShardFound response) {
- getSelf().tell(new RunnableMessage() {
- @Override
- public void run() {
- addShard(getShardName(), response, getSender());
- }
- }, getTargetActor());
+ getSelf().tell((RunnableMessage) () -> addShard(getShardName(), response, getSender()), getTargetActor());
}
@Override
}
private void doRemoveShardReplicaAsync(final String primaryPath) {
- getSelf().tell(new RunnableMessage() {
- @Override
- public void run() {
- removeShardReplica(shardReplicaMsg, getShardName(), primaryPath, getSender());
- }
- }, getTargetActor());
+ getSelf().tell((RunnableMessage) () -> removeShardReplica(shardReplicaMsg, getShardName(), primaryPath, getSender()), getTargetActor());
}
});
}
String.format("Failed to find local shard %s", shardName), failure)), self());
} else {
if(response instanceof LocalShardFound) {
- getSelf().tell(new RunnableMessage() {
- @Override
- public void run() {
- onLocalShardFound.accept((LocalShardFound) response);
- }
- }, sender);
+ getSelf().tell((RunnableMessage) () -> onLocalShardFound.accept((LocalShardFound) response), sender);
} else if(response instanceof LocalShardNotFound) {
String msg = String.format("Local shard %s does not exist", shardName);
LOG.debug ("{}: {}", persistenceId, msg);