Spring Интеграция с потребителем и Nifi в качестве диспетчера

Question

мы разрабатываем сервис, который прослушивает или принимает сообщение из очереди RabbitMQ. Сообщение отправляется из Apache Nifi в очередь сообщений (например, имя очереди - "рабочие элементы").

Теперь я хотел бы увидеть фрагмент кода с использованием Spring Integration для прослушивания и обработки этого сообщения, отправленного в очередь (RabbitMQ) от Apache Нифи.

Спасибо!

Answer 1

Похоже, вам нужен адаптер канала AMQP от Spring Integration: https://docs.spring.io/spring-integration/docs/5.3.0.M4/reference/html/amqp.html#amqp -inbound-channel-adapter

А вот пример по этому вопросу: https://github.com/spring-projects/spring-integration-samples/tree/master/basic/amqp