All Questions
Tagged with spring spring-integration
3,405
questions
-3
votes
0
answers
18
views
How to implement a Spring Integration service to poll from multiple tables in round-robin fashion and trigger individual batches? [closed]
I have a requirement where I need to implement a Spring Integration service that polls data from three tables (TABLE_A, TABLE_B, TABLE_C) in a round-robin manner and triggers individual batches based ...
0
votes
1
answer
25
views
Spring Integration: Multithreaded HTTP requests aggregation reply only for the last request that release the group and others get a timeout
I am trying to aggregate multiple http requests payload and process them together. So, i have created a spring boot app that contain:
a RestController: where i expect to get the payloads.
a ...
- 3
1
vote
1
answer
19
views
Spring Integration : Poller.fixedDealy not working as expected in multithreaded application
I have created an application using Spring Integration. It reads from the database converts the rows into XML format and sends it to Kafka.
I have used Executor to create Multiple threads for ...
0
votes
1
answer
73
views
How to solve the SPRING TCP SSL No subject alternative names present
I am trying to connect to a server using the TCP outbound gateway via SSL. I am making use of a ClientConnectionFactory. I implemented this
I also am using a custom TcpNetSSLSupport where I am ...
- 49
0
votes
1
answer
17
views
With publishSubscribeChannel, in spring integration, if one subscription fails will the other one still run?
Lets assume that the "throwsException" handler throws an exception. Normally, this will go to the error channel. However, will the second subscription still run? Will the message be sent ...
- 55
0
votes
1
answer
30
views
message-driven-channel-adapter - concurrent processing of messages
Issue
We have a legacy application with the following message-driven-channel-adapter configuration
<jms:message-driven-channel-adapter
id="processRequest"
destination=&...
0
votes
0
answers
34
views
Disconnect Kafka exception is not throwing error
I am using spring Integration kafka outbount channel to send the messages to Kafka and i am using handler advice to handle the response to update status in database table (Success OR failure ).
<...
- 35
0
votes
1
answer
75
views
Spring Integration TCP Server to Client request response
I've a use case where I need to make requests to an external system using TCP socket and wait for response. I know that Spring Integration Outbound Gateway can be used if I'm connected as a client.
...
0
votes
0
answers
49
views
Handling Redis Connection Events with Spring Boot Data Redis
With Spring Boot Data Redis, is there a way to detect and handle Redis connection activation and deactivation events?
I am using Spring Integration to listen to a Kafka topic, perform some processing, ...
-1
votes
1
answer
29
views
How to send a message to a flow in spring integration?
Suppose the following flow:
public IntegrationFlow sendFlow() {
return IntegrationFlow.from(inputChannel())
.handle("something","someMethod")
...
- 55
0
votes
1
answer
36
views
Aggregation with timeout and group size takes a lot of time
I have this integration flow
IntegrationFlows.from(MessageChannels.queue(MailPushGateway.SEND_MAIL_NOTIFICATION_CHANNEL, Integer.MAX_VALUE))
.enrichHeaders(headerEnricherSpec -> ...
0
votes
1
answer
34
views
Spring integration leak
I have a spring integration application. It basically has a gateway with its requestChannel, and a @ServiceActivator that consumes from the channel. The @ServiceActivator uses a poller to fetch new ...
- 1,684
1
vote
1
answer
34
views
Error while downloading with SftpInboundFileSynchronizingMessageSource Spring component a file to remove SFPT to a local directory
I have the following problem. I followed the documentation here and configured the SFTPInboundAdapter. An error occurs when the ssh client starts to download the file:
org.springframework.messaging....
- 803
0
votes
1
answer
85
views
Stream file in chunks with sftp streaming inbound adapter
I am using SFTP streaming inbound channel adapter, and it reads the entire file in one shot. It gives me an input stream that is later transformed by stream transformer I want to read the file ...
0
votes
1
answer
39
views
Exception Handling Sample in Spring Integration
I am looking for an good error handling example for spring integration. All I really want to do is a call a method, when this flow fails. The idea is the called method will send out an error email.
...
- 55