Я работаю с RabbitMQ в Java, используя AMQP. Мне нравится использовать аннотации, и у меня есть некоторые слушатели с форматом @RabbitListener. мой @RabbitListener
переход в другую очередь после выполнения ими обработки; Пример кода следующий:
@RabbitListener(queue = "testQueue")
void subscribeToTestQueue(Message message)
{
try {
// ... do processing
rabbitTemplate.convertAndSend(newQueue, processedMessage);
} catch (Exception e) {
// ... handle exception
}
}
Я ищу создание хорошо масштабируемой системы и, очевидно, смотрю на асинхронную asyncRabbitTemplate
. Я не могу понять, какую пользу это принесло бы мне, если бы я использовал его, учитывая, что @RabbitListener
уже сам асинхронен. Кроме того, если я внесу изменение, как должна измениться обработка ошибок?