Have a Spring Integration application consisting of multiple integration flows and altogether the application is deployed as a container in Kubernetes. The container is auto-scaled as per the load.

I am working on a project. My goal is to design a Spring IntegrationFlow using Version 6.3.2. that reads from a Sftp Server and splits and transforms the received XML files.

In Spring Integration, when creating IntegrationFlow, when event initiates a flow I have multiple operations, including splitter and filter. I would like to detect when all of the messages splitted has been processed.

I am dynamically registering multiple IntegrationFlows:

I have a Spring Integration flow that looks like the following (simplified)

This issue is an extension of the SO issue Spring Integration Restore ReactorContext into Imperative Processing

Is there a built in “transactional” mechanism when polling rows and updating?

With our complex IntegrationFlow that switches between Reactive and Imperative processing, we are seeing a behavior where the ObservationContext (traceId) is changed right after WebFlux.outboundGateway call.

I just spend a few hours debugging why my Spring Integration flow was not working. The flow uses a QueueChannel with a JdbcChannelMessageStore to implement an transactional outbox. However, the message was never stored in the database. If I replaced the queue with an in-memory one (Using MessageChannels.queue("test-queue")), then everything worked fine.

Does Spring Integration support SMPP (Short Message Peer-to-Peer) protocol? Have checked the documentation, couldn’t find one for SMPP in particular.