Pollable StreamListener or MessageSource for RabbitMQ Queue

Question

我有Spring Cloud Stream Rabbit项目，该项目在流程中出错时将消息发送到兔子交换errorEx。我想定期(每 5 分钟一次(从队列中收听并处理它。

有什么方法可以拥有可轮询@StreamListener吗？或者我可以配置 rabbitMQ org.springframework.integration.core.MessageSource以便我可以使用 Poller 构建IntegrationFlow吗？

Answer 1

Spring Integration AMQP 不提供可轮询的适配器。 @StreamListener仅支持Subscribable通道。

您可以使用使用RabbitTemplate receive()操作提取消息的自定义MessageSource。

或者，您可以使用消息驱动的适配器并根据需要对其进行stop()/start()。