8,109 questions
0
votes
0
answers
27
views
Polling on MongoDB message store backed QueueChannels during application shutdown [closed]
I have an application that uses Spring Boot 3.5.8 and its associated version of Spring Integration.
My application uses Spring Integration QueueChannels. For robustness, every QueueChannel bean is ...
- 53
Advice
0
votes
2
replies
40
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
1
replies
64
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
128
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
149
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,981
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
91
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.2k
2
votes
1
answer
53
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
63
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 ...
- 45
1
vote
0
answers
80
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
45
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
65
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.1k
0
votes
1
answer
61
views
Spring Cloud Stream RabbitMQ: NoUniqueBeanDefinitionException for ConversionService and cannot use @Primary
Question:
I’m building a Spring Boot application that uses Spring Cloud Stream with the RabbitMQ binder. My project pulls in several dependencies—Spring MVC, Spring Cloud Stream, Resilience4j (circuit ...
- 571
0
votes
1
answer
52
views
Spring Integration multiple integration flows, each with its own JDBC Inbound Channel Adapter
I want to read from 4 database tables using JDBC Inbound Adapters with polling. Each JDBC Inbound Adapter serves as the starting point of one of my 4 integration flows. Each flow is independent of the ...
- 3
