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

Question

我们正在开发一个服务来监听或消费来自 RabbitMQ 队列的消息。消息从 Apache Nifi 分派到消息队列（例如队列名称是“工作项”）。

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

谢谢！

标签： springspring-integrationspring-rabbit

Answer 1

听起来您需要来自 Spring Integration 的 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