Questions tagged [spring-integration]
Use this tag for questions about the Spring Integration project. It is not intended for general questions about integrating other Spring projects with other technologies.
spring-integration
8,022
questions
0
votes
0
answers
2
views
Inspecting payload to an outbound FTP adapter with MockIntegrationContext
I have a Spring Integration flow that looks like the following (simplified)
@Bean
public StandardIntegrationFlow integrationFlow() {
return IntegrationFlows.from(inputChannel())
....
1
vote
0
answers
25
views
spring-integration-sftp failed to send channel
I have a spring-integrations-sftp configuration like below, basically it listens a remote directory and fetch the files and deletes afterwards.
@Bean
public SessionFactory<ChannelSftp.LsEntry&...
-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
0
answers
36
views
Netty blocking spring integration workers
Currently I’m working on a spring integration service that uses webClient with Netty for http calls
The problem that I'm facing occurs when spring integration goes to a channel and while it is ...
0
votes
1
answer
21
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 ...
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
0
answers
12
views
how to send request from integration flow to an external rest api application and get response
The incoming triggered message is a list of object.
@Bean
public IntegrationFlow requestReplyFlow() {
return IntegrationFlow
.from(requestChannel())
.handle(Http
...
0
votes
1
answer
70
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 ...
1
vote
0
answers
18
views
Spring Integration: META-INF/spring.integration.properties file not being recognized in Spring Boot application
According to
https://docs.spring.io/spring-integration/api/org/springframework/integration/context/IntegrationProperties.html and
https://github.com/spring-projects/spring-integration/issues/8704
I ...
0
votes
1
answer
16
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 ...
0
votes
1
answer
17
views
How to Access the Request Path in Spring Integration InboundChannelAdapter
I have a Spring Integration DSL Flow and I'm trying to access the HTTP request path. Possible paths look something like this
/import: imports everything
/import/case1: imports only part A
/import/...
1
vote
1
answer
75
views
How to resolve NO OUTPUT or CHANNEL REPLY HEADER
For a threeway communication between two external applications built with something different and my springboot app
External client 1 always initiates communication via TCP socket
Springboot ...
1
vote
1
answer
35
views
Why can I connect via telnet but connection cannot be established from a remote client?
I am writing a spring boot application which acts as a sort of middle man between two external clients say serviceA and serviceB. Communication will be via socket connection i.e. tcp/ip allthrough.
So ...
0
votes
1
answer
29
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
1
answer
52
views
Spring Integration how to dynamically set local directory/remote directory based on message to either sent to a remote sftp or get files from it
I'm currently trying to made changes to a project that uses Spring integration to send and receive Files from/to a SFTP server.
The changes consist of adding other SFTP servers, choose the right ...