Слушайте очереди RabbitMQ и получать уведомления о событиях

Question

В настоящее время я занимаюсь разработкой приложений Java с помощью Spring AMQP с RabbitMQ и хотел бы контролировать свои очереди и быть информированным, если некоторые события происходят, как

• элемент был добавлены в очереди,
• элемент был удален или
• элемента был, но в очереди снова (отката).

Как я могу слушать такие события или что такое RabbitMQ-способ делать такие вещи?

Answer 1

Чтобы получить сообщение асинхронно из очереди, необходимо использовать инфраструктуру конечных точек аннотированного прослушивателя. В двух словах, это позволяет вам выставить метод управляемого компонента в качестве конечной точки слушателя кролика.

@Component 
public class MyService { 

    @RabbitListener(queues = "myQueue") 
    public void processOrder(String data) { 
     ... 
    } 

} 

Проверить this Всякий раз, когда сообщение помещается в очередь myQueueprocessOrder метод срабатывает.

Для выполнения других требований вы также можете использовать spring events для контроля за любой работой, выполняемой в очереди. Как раз перед выполнением любой операции в очереди будет инициировано соответствующее событие.