911 questions
- Bountied 0
- Unanswered
- Frequent
- Score
- Trending
- Week
- Month
- Unanswered (my tags)
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 ...
3
votes
1
answer
151
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. ...
0
votes
1
answer
48
views
Message sometimes doesn't get sent over StandardIntegrationFlow channel
I have a SpringBoot application using version 3.4.1 and also Spring Integration 6.4.1.
I am creating WebSockets dynamically, upon an HTTP request, to which I send messages from different threads.
The ...
2
votes
1
answer
71
views
Spring Integration Concurrent execution of JDBC Inbound Channel Adapter
I have a spring integration microservice which has an integration flow starting from an Jdbc Inbound Channel adapter.
When using JDBC inbound channel adapter in an integration flow, we can set an ...
1
vote
1
answer
51
views
Stopping message flow in the middle of a Spring integration flow
I have a spring integration flow which listens to JMS messages using the Java DSL through the use of a JMS messageDrivenChannelAdapter. It has a subflow as follows:
f -> f.handle(ServiceA)
....
1
vote
1
answer
38
views
How to extend Spring Integration IntegrationFlowBuilder with convenience functions?
We are using Spring Integration Flows in a project to create an api out of incoming kafka events.
While using these flows certain patterns have emerged in how we use them.
To keep our code short and ...
2
votes
1
answer
64
views
Spring Integration - recommended splitter/aggregator setup for async subflow replying in an undefined time in the future
I currently have a flow with a splitter and an aggregator that uses a gateway to call another complex flow with asynchronous subflows.
Currently I have the gateway configured with a replyTimeout set ...
2
votes
1
answer
73
views
Spring Integration flow failing after migration to Spring Integration 6.x failure occurred in gateway sendAndReceive No reply produced by handler
I recently upgraded a project from Spring Integration 5.x to 6.4.4. Everything is working other than one flow setup that is failing and it is hard to see why. (It was working fine before).
It is quite ...
0
votes
1
answer
68
views
How to handle closing ExecutorService when used with Spring Integration Flows?
I am using an executor service to ensure that incoming jms messages are acknowledged after I write them to my database - (Using XA datasources and distributed transaction is not an option we have ...
0
votes
1
answer
79
views
How to add a header and/or a footer to a file using SFTP Outbound Adapter?
I am consuming messages from Kafka and writing those to a file using SFTP Outbound Adapter on a remote file server. The application will run multi-instance in the cloud environment.
I am using leader ...
1
vote
1
answer
68
views
spring integration DSL Flow to another Flow does not execute enrichedHeaders
I am using Spring Integration 6.3.3. I have our main IntegrationFlow consuming from a PubSubInboundAdapter defined like this:
@Bean
public MessageChannel channelA() {
return new DirectChannel();
}
...
0
votes
1
answer
35
views
Split, route, aggregation logic doesn't work
I'm trying to create an implementation of the IntegrationFlowAdapter class that would allow me to take a push notification, copy it for each device token, split the push notification list and have it ...
0
votes
1
answer
29
views
Unable to repoll failed message from JDBC when aggregate is used in the integration flow
My current workflow has 2 integration flows-
First Integration Flow- Polls files from SFTP -> Message Handler -> sends messages to JdbcChannelMessageStore and saves those messages in Jdbc under ...
1
vote
1
answer
105
views
Spring Integration error channel header ignored in flow
I am trying to build complex Spring Integration flows where parts of the flows need to handle error scenarios and provide a different branches in the flow that will skip some processing and continue ...
1
vote
1
answer
90
views
Spring Integration : do something when timeout occure
I'm waiting for a message to come, but when it doesn't I want to do some calculation.
Something like the following (what I want):
IntegrationFlows.from(messageChannel)
.timeout(1, ...