Examples of org.springframework.amqp.rabbit.retry.MessageRecoverer.recover()

      public Void recover(Object[] args, Throwable cause) {
        Message message = (Message) args[1];
        if (messageRecoverer == null) {
          logger.warn("Message dropped on recovery: " + message, cause);
        } else {
          messageRecoverer.recover(message, cause);
        }
        // This is actually a normal outcome. It means the recovery was successful, but we don't want to consume
        // any more messages until the acks and commits are sent for this (problematic) message...
        throw new ImmediateAcknowledgeAmqpException("Recovered message forces ack (if ack mode requires it): "
            + message, cause);

      public Void recover(Object[] args, Throwable cause) {
        Message message = (Message) args[1];
        if (messageRecoverer == null) {
          logger.warn("Message dropped on recovery: " + message, cause);
        } else {
          messageRecoverer.recover(message, cause);
        }
        return null;
      }
    });

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.