8,107 questions
2
votes
1
answer
16
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 ...
- 67
0
votes
1
answer
65
views
Best practices for error handling in synchronous spring integration flows
We are using Spring Integration to consume kafka messages, process them, save them to database and publish them to another kafka. For this we are using a set of spring integration flow, most of them ...
- 67
Best practices
0
votes
1
replies
44
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
41
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 ...
- 829
Advice
1
vote
1
replies
66
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 ...
- 829
2
votes
1
answer
131
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
154
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,983
0
votes
0
answers
40
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
96
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
67
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
58
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
65
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
85
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-...
0
votes
0
answers
48
views
Distributed lock in JdbcLockRegistry during execute slow SQL procedure
I have problem with trylock() in Spring Integration framework, when slow sql procedure is executing. I have 2 instances of Spring Boot microservices.
My flow:
schedule poller by Pollers.cron -> ...
1
vote
1
answer
67
views
Spring Boot Autoconfiguration fallback bean factory
The title could be a little misleading because @Fallback annotation exists. And what I am asking is similar to this related question but requires bean names. Let's start with the...
Context
I have a ...
- 27.2k
