LOG.debug("{}: Adding message {} to retry", shard.persistenceId(), message);
MessageInfo messageInfo = new MessageInfo(message, replyTo, failureMessage);
LOG.debug("{}: Adding message {} to retry", shard.persistenceId(), message);
MessageInfo messageInfo = new MessageInfo(message, replyTo, failureMessage);