}
void retryMessages() {
- if(messagesToRetry.isEmpty()) {
+ if (messagesToRetry.isEmpty()) {
return;
}
MessageInfo[] copy = messagesToRetry.toArray(new MessageInfo[messagesToRetry.size()]);
messagesToRetry.clear();
- for(MessageInfo info: copy) {
+ for (MessageInfo info: copy) {
LOG.debug("{}: Retrying message {}", shard.persistenceId(), info.message);
info.retry(shard);
}
@Override
public void close() {
- for(MessageInfo info: messagesToRetry) {
+ for (MessageInfo info: messagesToRetry) {
info.timedOut(shard);
}
}
void timedOut(Shard shard) {
- replyTo.tell(new Failure(new NoShardLeaderException(failureMessage, shard.persistenceId())), shard.getSelf());
+ replyTo.tell(new Failure(new NoShardLeaderException(failureMessage, shard.persistenceId())),
+ shard.getSelf());
}
}
}