用於RabbitMQ隊列的Pollable StreamListener或MessageSource

我有Spring Cloud Stream Rabbit項目，在流程中發生錯誤時向兔子交換機發送消息errorEx。我想定期（5分鐘一次）從隊列中偵聽並處理它。用於RabbitMQ隊列的Pollable StreamListener或MessageSource

有沒有什麼辦法可以讓Pollable @StreamListener？或者我可以配置一個rabbitMQ org.springframework.integration.core.MessageSource，所以我可以用Poller構建一個IntegrationFlow？

來源

2017-06-20 MajorXbox

彈簧集成AMQP不提供可輪轉的適配器。 @StreamListener僅支持Subscribable頻道。

您可以使用自定義MessageSource使用RabbitTemplate 操作來獲取消息。

或者，您可以根據需要使用消息驅動適配器和stop()/start()。

來源

2017-06-20 23:31:20

在我能夠執行'rabbitTemplate.receive（）'的地方使用'CustomMessageSource'。然後將其用於IntegrationFlow中的輪詢器。 IntegrationFlows.from（customMessageSource，c - > c.poller（Pollers.fixedDelay（10000，10000）.maxMessagesPerPoll（1）））.channel（retryChannel（））。get（）' – MajorXbox

用於RabbitMQ隊列的Pollable StreamListener或MessageSource

回答

相關問題