[FEATURE REQ] Pollable channel in Spring Integration for Event Hubs and Service Bus

[yiliuTo]

Context

Currently the consumer model of spring integration Event Hubs/Service Bus is a reactive mode since we use the processor clients from SDK, spring integration also supports the polling mode.
Ref: KafkaMessageSource

Solution

• Implement a pollable consumer with the pulling consumer/receiver clients from SDK, tracked in issue [Feature Request] Support both sync and async sender/receiver #21538
• Implement a pollable channel model of AbstractMessageSource for a polling mode.

[sravaniv-3cortex]

@yiliuTo @stliu I am trying to implement Spring Cloud Data Flow Task Launcher Sink with Spring Cloud Stream Event Hubs Binder, which requires polling consumer support and EventHubsMessageChannelBinder doesn't implement createPolledConsumerResources and postProcessPollableSource methods. I found this when seeing if there is any plan to support this. I have moderate knowledge of Event Hubs but have a very basic idea of Spring Integration.

How big of an effort this would require if I want to implement this either by myself or contribute to the event hubs stream binder?
At a high level, my understanding is that we should implement the following:

• AbstractMessageSource as mentioned in the issue description, which can use EventHubsConsumerClient (??)
• Adding polling support to EventHubsMessageChannelBinder
• Partitioning and acknowledging support

I considered using the AmqpMessageSource, part of Spring Integration RabbitMQ. I am unsure if Spring Integration authors would be okay refactoring that to Spring Integration Amqp support. The explanation in this issue #27052 helped a bit with the polling support understanding.

[github-actions]

Hi @yiliuTo, we deeply appreciate your input into this project. Regrettably, this issue has remained inactive for over 2 years, leading us to the decision to close it. We've implemented this policy to maintain the relevance of our issue queue and facilitate easier navigation for new contributors. If you still believe this topic requires attention, please feel free to create a new issue, referencing this one. Thank you for your understanding and ongoing support.