I have Spring Cloud Stream Rabbit project that sends messages to an rabbit exchange errorEx
in case of errors in the flow.
I want to periodically(once in 5 mins) listen from the queue and process it.
Is there any way I can have a Pollable @StreamListener
?
OR Can I configure a rabbitMQ org.springframework.integration.core.MessageSource
so I can build a IntegrationFlow
with a Poller?