Questions tagged [spring-integration-dsl]
861 questions
9
votes
1 answer
Spring Integration error "no output-channel or replyChannel header available"
I am not sure why I am getting the exception
Caused by: org.springframework.messaging.core.DestinationResolutionException: no output-channel or replyChannel header available
Its just a simple IntegrationFlow but not sure what am I missing here in…
Wizard
- 1,154
- 2
- 14
- 41
8
votes
1 answer
How can I map incoming headers as String instead of byte[] in my Spring Cloud Stream project?
I have a simple Spring Cloud Stream project using Spring Integration DSL flows and using the Kafka binder. Everything works great, but message header values coming from Kafka arrive as byte[].
This means that my SI @Header parameters need to be of…
Gabriel Bauman
- 2,270
- 1
- 22
- 36
8
votes
1 answer
How to mock WebFluxRequestExecutingMessageHandler with MockIntegrationContext.substituteMessageHandlerFor
I have implemented an IntegrationFlow where I want to do to following tasks:
Poll for files from a directory
Transform the file content to a string
Send the string via WebFluxRequestExecutingMessageHandler to a REST-Endpoint and use an AdviceChain…
Eli
- 117
- 7
7
votes
1 answer
Spring Integration 5.1 - integration flow convertion with @IntegrationConverter doesn't work
I upgrade my Spring boot version from 2.0.5.RELEASE to 2.1.8.RELEASE (so Spring Integration from 5.0 to 5.1) and the automatic type casting inside integration flow doesn't work anymore. I am used to define a set of @IntegrationConverter components…
Kruschenstein
- 283
- 4
- 12
7
votes
1 answer
TaskExecutor is not working Spring Integration
I have setup File poller with task executor
ExecutorService executorService = Executors.newFixedThreadPool(10);
LOG.info("Setting up the poller for directory {} ", finalDirectory);
StandardIntegrationFlow…
Makky
- 17,117
- 17
- 63
- 86
7
votes
1 answer
There's some way to generate diagrams for spring integration dsl flows?
I have a running app that defines some spring integration flows with inbound/outbound gateways, splitters, aggregators,routers and etc...
These flows are all created using spring integration dsl and annotations... so no XML's.
There is any tool out…
Lucas Oliveira
- 3,357
- 1
- 16
- 20
5
votes
1 answer
Use Spring Integration DSL to read from Tibco EMS topic
I've been trying to configure spring integration dsl to read from a Tibco EMS topic , do some processing on the received message and then push it to an ActiveMQ queue. I was able to set this up successfully using XML configuration, but wanted to use…
Adee J
- 75
- 1
- 5
4
votes
1 answer
Spring Integration DSL Filter vs. RouteToRecipients w/ single Recipient and DefaultOutputToParentFlow
I am needing to route a message from my parent flow into a new flow when a given evaluation returns false but have it continue in the parent flow when that evaluation returns true. Currently I have been able to successfully implement this…
chimiz13
- 75
- 7
4
votes
2 answers
How to dynamically define file filter pattern for Spring Integration SFTP Inbound Adapter?
I need to dynamically pull specific files from different directories from different sftp servers to a local server directory of a spring boot application.
I store the paths and a file pattern in a postgres database. I got everything working but i…
Thomas H.
- 63
- 2
- 9
4
votes
1 answer
Spring-Integration Webflux exception handling
If an exception occurs in a spring-integration webflux flow, the exception itself (with stacktrace) is sent back to the caller as payload through MessagePublishingErrorHandler, which uses an error channel from the "errorChannel" header, not the…
dschulten
- 2,994
- 1
- 27
- 44
4
votes
1 answer
How to process more than 10 concurrent messages from an AWS SQS FiFo queue using Spring Integration
I want to be able to process more than 10 SQS messages at a time using a Spring Integration Workflow.
From this question, the recommendation was to use an ExecutorChannel. I updated my code but still have the same symptoms.
How execute Spring…
Steve
- 154
- 1
- 11
4
votes
1 answer
How to Unmarshall XML from JMS queue Using spring integration dsl
Since i do no have enough reputation to comment on the other topic open about this
(How to unmarshall xml using spring integration dsl)
I had to create a new topic in order to ask my question.
I have a JMS which polls XML messages from a queue, and…
alext
- 678
- 1
- 11
- 25
4
votes
1 answer
Dynamic TCP Server with Spring Integration using Java DSL
I am trying to create a TCP server and client by reading the property files which contains the detail of the connections.
I am using Dynamic and runtime Integration Flows with the help of following reference document (
9.20 Dynamic and runtime…
shivam tiwari
- 111
- 9
3
votes
1 answer
How to handle bulk operations in Spring Integration
we are developing a Spring Integration Flow using Java DSL. This application reads from a remote File and inserts data in MongoDB. We are streaming the file lines and we need to bulk-insert data in MongoDB. From my understanding of the Spring…
tommaso.normani
- 260
- 2
- 12
3
votes
0 answers
Send messages from a BlockingQueue through a dynamically created web socket using Spring Integration
I have a SpringBoot application that also uses SpringIntegration to dynamically create web sockets upon requests that come from an Angular web application and send messages on that web sockets that are taken from a BlockingQueue.
I want those…
Andrei Roșu-Cojocaru
- 481
- 1
- 5
- 16