8,105 questions
0
votes
1
answer
43
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 ...
- 175
3
votes
1
answer
38
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 ...
2
votes
1
answer
58
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 ...
- 43
4
votes
1
answer
62
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 ...
- 101
Best practices
0
votes
1
replies
46
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 ...
- 612
Advice
0
votes
2
replies
43
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 ...
- 831
Advice
1
vote
0
replies
70
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 ...
- 831
2
votes
1
answer
135
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 ...
3
votes
1
answer
158
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. ...
- 7,993
0
votes
0
answers
44
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 ...
- 835
0
votes
1
answer
103
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 ...
3
votes
1
answer
68
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,
...
- 27.3k
2
votes
1
answer
66
views
Spring Integration WebFlux - Kotlin DSL: Consuming SSE
Currently I'm in the process of porting an previously working application which consumes ServerSentEvents (SSE) using Spring Integration WebFlux from Java to Kotlin.
The former worked in Java using ...
- 197
2
votes
1
answer
66
views
Why does Spring Cloud Function invoke the first part of a composed function twice?
I have built a Spring Cloud Function application with a Spring Integration flow exposed as a function (actually, an imperative Consumer) and a reactive Function. Both functions are composed and ...
- 77
1
vote
0
answers
88
views
message-driven-channel-adapter stop receiving messages after a couple of days
I'm having an issue that I'm unable to solve it.
Here is the following scenario
In my application I'm creating an Entity and then I send that entity as XML in in a Queue.
Then I'm having an outound-...
