I am using Spring Integration Streaming Inbound Channel Adapter, to get stream from remote SFTP and parse every lines of content process. I use : IntegrationFlows.from(Sftp.inboundStreamingAdapte...

I have a simple Spring Cloud Stream project using Spring Integration DSL flows and using the Kafka binder. Everything works great, but message header values coming from Kafka arrive as byte[]. Thi...

I upgrade my Spring boot version from 2.0.5.RELEASE to 2.1.8.RELEASE (so Spring Integration from 5.0 to 5.1) and the automatic type casting inside integration flow doesn't work anymore. I am used t...

This is variant of my question How to implement simple echo socket service in Spring Integration DSL. A good working solutions was introduced but I would like to explore alternatives. Particularly ...

Please, could you help with implementation of a simple, echo style, Heartbeat TCP socket service in Spring Integration DSL? More precisely how to plug Adapter/Handler/Gateway to IntegrationFlows on...

Why channel can be set on TcpReceivingChannelAdapter, the inbound adapter, but not on TcpSendingMessageHandler, the outbound adapter? Why outbound adapter is called TcpSendingMessageHandler, why h...

I have setup File poller with task executor ExecutorService executorService = Executors.newFixedThreadPool(10); LOG.info("Setting up the poller for directory {} ", finalDirectory); StandardInt...

My situation is similar to the one described in this SO question. The difference being that I don't use a WebFlux.outboundGateway but an Ftp.outboundGateway on which I call an AbstractRemoteFileOut...

I have implemented an IntegrationFlow where I want to do to following tasks: Poll for files from a directory Transform the file content to a string Send the string via WebFluxRequestExecutingMess...

I have a spring integration flow defined in the flow DSL syntax. One of my handlers is a Webflux.outboundGateway. When the remote URI is not accessible, an exception is thrown and sent to the "erro...

I am not sure why I am getting the exception Caused by: org.springframework.messaging.core.DestinationResolutionException: no output-channel or replyChannel header available Its just a simple I...

I have a running app that defines some spring integration flows with inbound/outbound gateways, splitters, aggregators,routers and etc... These flows are all created using spring integration dsl a...