Я написал MessagePostProcessor, который вызывается до вызова любого потребителя onMessage.
Теперь, если в моем MessagePostProcessor возникает какое-либо исключение, мне нужно поймать исключение, иначе сообщение будет бесконечно запрашиваться на сервере Rabbitmq Q, снова и снова возвращаясь туда и сюда. Итак, исправьте эту проблему, мне нужно поймать исключение в моем компоненте MessagePostProcessor, но из-за этого потребители не получают правильную проблему для проблемы на своем конце.
Какова наилучшая практика обработки таких сценариев.
Псевдо-сообщениеПостпроцессор
@Service
public class TestPostProcessor implements MessagePostProcessor {
/**
* {@inheritDoc}
*/
@Override
public Message postProcessMessage(Message message) {
try {
// some logic
} catch (Exception exception) {
// log error
}
return message;
}
}