Cómo pedirle a RabbitMQ que vuelva a intentar cuando ocurra una Excepción comercial en el caso de uso de Spring Asynchronous MessageListener
Tengo un escucha de mensajes Spring AMQP ejecutándose.
public class ConsumerService implements MessageListener {
@Autowired
RabbitTemplate rabbitTemplate;
@Override
public void onMessage(Message message) {
try {
testService.process(message); //This process method can throw Business Exception
} catch (BusinessException e) {
//Here we can just log the exception. How the retry attempt is made?
} catch (Exception e) {
//Here we can just log the exception. How the retry attempt is made?
}
}
}
Como puede ver, podría haber una excepción durante el proceso. Quiero volver a intentarlo debido a un error particular en el bloque Catch. No puedo por excepción en onMessage. ¿Cómo decirle a RabbitMQ que hay una excepción y volver a intentarlo?