Spring 与消费者和 Nifi 作为调度程序集成

Question

我们正在开发一种服务，用于侦听或使用来自 RabbitMQ 队列的消息。消息从 Apache Nifi 发送到消息队列（例如队列名称是 "workitems"）。

现在，我想看一个代码片段，它使用 Spring 集成来侦听和处理从 Apache Nifi 发送到队列 (RabbitMQ) 中的这条消息。

谢谢！

Answer 1

听起来您需要 Spring 集成的 AMQP 通道适配器：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