Questions tagged [spring-integration-dsl]
The spring-integration-dsl tag has no usage guidance.
spring-integration-dsl
905
questions
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 ...
- 4,528
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/...
- 4,528
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 ...
- 49
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 ...
- 49
0
votes
0
answers
6
views
How to use multiple persistent TCP connection with server using TCPNetClientConnectionFactory as base factory
I want to send 2 payloads for 1 transaction over single persistent connection to server. I tried using cachingClientConnectionFactory and ThreadAffinityClientConnectionFactory. But since those both ...
0
votes
0
answers
21
views
how to implement a sliding time-window aggregator with Spring-Integration DSL?
I have an InboundChannelAdapter receiving heartbeat messages from external processes. Each external process sends a heartbeat message every 10 secs to that inbound adapter with its process-name as ...
- 535
0
votes
1
answer
45
views
Spring Integration TCP Client unable to receive messages from external TCP Server
I've a use case where I need to send messages to an external TCP Server with 2 IP/ports for Round Robin distribution (each connection for each pair of IP/port, and it should be keep-alive for message ...
- 11
0
votes
1
answer
32
views
spring integration error: one-way 'MessageHandler' and it isn't appropriate
I am writing a simple Integration flow to sftp a file to a remote server and want to stop the temporary file renaming on the remote server.
In order to achieve this, I tried creating the following ...
- 5,807
0
votes
0
answers
32
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
1
vote
1
answer
41
views
How to handle input data with IntegrationFlowExtension
I want to create create a custom spring integration DSL to avoid boilerplate code in our product. More concrete, we are creating a lot of flows where we receive data from an AMQP0.9 queue, transform ...
- 91
0
votes
1
answer
26
views
Spring Integration Java DSL TCP outbound and Inbound Connection Handler
I need to create a dynamic TCP outbound adapter that acts as a client, connects to a server, and handles the server's response. While the request is being sent to the server correctly, I am unable to ...
- 15
1
vote
1
answer
22
views
junit testing integrationFlow with serviceActivator
in my spring-boot project i have the following class :
@Configuration
@EnableIntegration
public class ConsumeFiles {
@Bean
public IntegrationFlow inboundFileFromDirectory(@Value("${...
- 51
0
votes
1
answer
35
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
41
views
Migrating from spring integration 5.5 to 6.3
Given we no longer have IntegrationComponentSpec.get() and the correct solution is to use the ChannelSpec rather than the Channel. But how would I apply this with Kotlin DSL?
Before I could do:
@...
- 281
1
vote
1
answer
18
views
@Role in IntegrationFlow DSL
Is it possible to specify the endpoint role used for leadership election through the IntegrationFlow dsl when using a message driven channel adapter?
I can create a JMS message driven endpoint using ...
