I have Spring Integration QueueChannel that I want to consume in backpressure aware Flux pipeline. Prefetch n Messages from the queue. Make async calls to external system like fun remoteCall(message: Message): Mono<Void>. Pull next message(s) from the queue after external calls will complete. I don’t want to use Poller with scheduler to pull messages from the queue ahead of time.
Tag: spring-integration
How to add transaction support to Java DSL integration flows
I have to add a transaction support to an integration flow. Let’s assume that there are 3 transformers. The first and third transformers should be done within the same transaction, but the second one shouldn’t be done within any transaction. Thus, if an error occurs in the third transformer, all changes from the first and third transformers should not be
Spring SFTP : Unable to rename .writing file
I am using Spring SFTP integration to transfer the file and many time I got this error. It seems two threads are trying to transfer same file and conflict with each other 2020-08-03 08:31:55,766 INF [task-scheduler-8 ] o.s.i.ftp.session.FtpSession – File has been successfully transferred from: ./abc.ext.200803 2020-08-03 08:31:55,849 INF [task-scheduler-7 ] o.s.i.ftp.session.FtpSession – File has been successfully transferred from: ./abc.ext.200803
How to get the file from service-activator Message object in listener class
I need to pass the file to service layer which i am receiving in SFTP path. below is configuration and i am seeing the message receiving in my service-activator like GenericMessage [payload=com….
Break the Transformer flow Spring Integration
I have spring integration flows. One for the file poller and other one is to process the file flow # 01 poll the file in C:/testing directory files comes goes to “process” queue flow # 02 (from “process”) The issue is if the FindTheDepartItBelongs cannot find the department then it has to stop the rest of the flow and send
When to use Spring Integration vs. Camel?
As a seasoned Spring user I was assuming that Spring Integration would make the most sense in a recent project requiring some (JMS) messaging capabilities (more details). After some days working with Spring Integration it still feels like a lot of configuration overhead given the amount of channels you have to configure to bring some request-response (listening on different JMS