8,104 questions
Score of 0
0 answers
52 views
Cannot configure AMQP acknowledge-mode with application property
Using Spring Integration 4.1.0, setting up an IntegrationFlow as follows,
Log4j2
@Configuration(proxyBeanMethods = false)
public class RabbitConfig {
@Bean
public SimpleConsumer ...
Score of 3
2 answers
133 views
Spring Integration runtime errror: No request channel available. Cannot send request message
I run into an issue after migrating from SpringBoot 3 to SpringBoot 4. Trying to send files over SFTP with MPUT says there is no channel:
2026-06-16T10:15:10.331217825Z ERROR [] --- [cdb-job-thread3] ...
Score of 1
0 answers
54 views
Spring integration SMB: "unknown user name" when username contains "@" character
I'm having trouble using spring-integration-smb: when I try to authenticate a user whose name contains an "@", I get the error message "unknown user name". Interestingly, if I ...
Score of 0
1 answer
55 views
Spring Integration persistent QueueChannel with single-threaded execution
Do we have support for enabling single threaded execution on a persistent (PostgreSQL) QueueChannel as how it is available for PublishSubscribeChannel? Use-case is to process the transactions in the ...
Score of 3
1 answer
47 views
Spring Integration 7.0.x SftpPersistentAcceptOnceFileListFilter SftpClient.DirEntry longFilename
Why in Spring Integration 7.0.x SftpPersistentAcceptOnceFileListFilter method fileName is changed to return longFilename?
eg.: for file name on SFTP server: FILENAME.txt and prefix 'prefix_' , in ...
Score of 2
1 answer
69 views
Kotlin SFTP inbound; Spring integration. How to delete local file if i got exception while sending message to handling channel?
I am getting files from different SFTPs via SftpInboundFileSynchronizer, handling and deleting afterwards despite handling result. I'am using separate threadPools for polling and handling.
The main ...
Score of 4
1 answer
80 views
Autowiring NullChannel for Spring Integration 7 / Spring Boot 4
I am attempting to upgrade from Spring Boot 3.5 to 4.0, which includes an upgrade to spring integration 7, but am having trouble autowiring my nullChannel.
In the previous version I have often ...
Best practices
0
votes
1
replies
51
views
how to use spring integration splitter using jpa stream in a tranaction but not apply the transaction to the splitter flow
I have a setup where I have a splitter that gets a recordset stream (sql driver streaming) from a service that uses jpa and hibernate. I then want to have the flow of the splitter not use the same ...
Advice
0
votes
2
replies
44
views
Spring integration flow. Using '.handle' with class param results to null. What am I doing wrong?
Continue learning IntegrationFlows.
Question of the day. How to properly use .handle(MyCustomPojo.class, (message, payload) -> ...)?
I have defined a MyCustomPojo with lombok's NoArgs/AllArgs and ...
Advice
1
vote
0
replies
79
views
Applying conditional routing in Spring Integration flow
I'm trying to understand how to properly define routes for Spring's IntegrationFlows.
I have a MQTT source, which is implemented as a MqttPahoMessageDrivenChannelAdapter.
From there I receive messages ...
Score of 2
1 answer
156 views
Received request message is changed from TCP server after upgrading Spring boot to 3.4.2
After upgrading Spring Boot from 2.7 to 3.4, receiving message from TCP server to our service is getting changed with different code. For example, previously the received message is 1784 after ...
Score of 3
1 answer
164 views
How to convert a database polling service to a Spring IntegrationFlow
I have a service that polls a database within a transaction, always removing the record and if an exception is thrown during processing adds a new record incrementing the 'try count' for that entry. ...
Score of 0
0 answers
50 views
Spring Integration Release Strategy Fails After Caught Exception
I have a high volume of messages being put on a QueueChannel. Each Object will have multiple updates (different hashCode, same equals(), different attribute values) that are written in time-event ...
Score of 0
1 answer
118 views
Spring Batch Remote Partitioning: Worker replies reach channel but manager never receives them
I'm implementing Spring Batch remote partitioning with Spring Integration and Kafka as a middleware. Worker replies successfully arrive at the managerInboundReplies channel (confirmed via interceptor ...
Score of 3
1 answer
72 views
How to read or publish concurrently with partitition key
I am using Spring Integration to implement the Transactional Outbox Pattern. I have code like this:
@Bean
IntegrationFlow eventFlow(
JdbcChannelMessageStore jdbcChannelMessageStore,
...