I have an Integration flow which logs on to a remote website. The flow then continually POSTs data to a URL. On Spring Boot shutdown, I wish to run a POST which runs a log-out.

I want to send 2 payloads for 1 transaction over single persistent connection to server. I tried using cachingClientConnectionFactory and ThreadAffinityClientConnectionFactory. But since those both needs single-use=true, its not fulfilling my purpose. It is creating multiple tcp connections but new connections for each payload. Can you suggest the right approach to achieve this? @Gary Russell

I have an InboundChannelAdapter receiving heartbeat messages from external processes. Each external process sends a heartbeat message every 10 secs to that inbound adapter with its process-name as the heartbeat message payload.
I want my DSL integration-flow aggregator to produce a message with a list of “alive” process-names, “alive” being defined as a process having sent a heartbeat within the last 30secs. The aggregator should produce a new output message (with a list of “alive” process-names) each time it acquires a new/unknown “alive” process or loses an existing/known one.
Thanks a lot in advance for your expertise and your time.
Best Regards

I have an InboundChannelAdapter receiving heartbeat messages from external processes. Each external process sends a heartbeat message every 10 secs to that inbound adapter with its process-name as the heartbeat message payload.
I want my DSL integration-flow aggregator to produce a message with a list of “alive” process-names, “alive” being defined as a process having sent a heartbeat within the last 30secs. The aggregator should produce a new output message (with a list of “alive” process-names) each time it acquires a new/unknown “alive” process or loses an existing/known one.
Thanks a lot in advance for your expertise and your time.
Best Regards