I am new to Spring Integration so please forgive and correct me if my question is absurd. I am trying to write Unit test cases for Spring Integration application where I am testing only controller and looking to mock service call.
Test:
@R…
Given the following spring integration configuration
…
import org.springframework.integration.ftp.session.FtpRemoteFileTemplate;
@Configuration
public class FtpConfig {
@Bean
@Scope("prototype")
public FtpRemoteFi…
I am designing a Spring boot application with spring integration to connect to TCP servers.
There will be multiple servers (not a part of this application) for which we would need those many clients (part of application). Once the socket c…
How can I setup a reactive flow using DSL for the following steps:
Receive an SQS Message using SqsMessageDrivenChannelAdapter
Validate the Json message [JsonSchemaValidator class with validate method]
Transform the json to objects
Pass t…
I would like to convert incoming message to one POJO class object, from the converted POJO class object to other POJO class object. Like, Message->Delivery1->Delivery2
public Message<Delivery2<?>> tranform(Message<Stri…
It seems i don’t understand some underlying concepts about custom Exceptions handling in Spring Integration(
I need to intercept some of my RuntimeException-derived custom exceptions (thrown from some my Java method) and depending of it’s …
It seems i don’t understand some underlying concepts about custom Exceptions handling in Spring Integration(
I need to intercept some of my RuntimeException-derived custom exceptions (thrown from some my Java method) and depending of it’s …
I need to use a PayloadTypeRouter and want to send the routed message directly into a Transformer, Filter or ServiceActivator. All should be configured with Kotlin DSL (or Java DSL).
Currently, a nice looking part of code looks like this:
…
I have a problem where I cannot set up process to go to both channels in parallel, it either goes one or another. I have one ServiceActivator and one Transformer that have the same input channel objectOutputChannel. After going to the proc…
It is a Spring Integration (based on Spring Boot) project, I’ve configured Spring Integration application as below,
Configuration xml:
<int:channel id="httpChannel"/>
<int-http:inbound-gateway supported-methods="…
I have a process where I need to upload file to Sftp server asynchronously. So after exploring more about Async in gateways I found that I need to have error channel defined in @MessagingGateway parameter then handler to handle the Excepti…
My spring integration application reads files from a fileshare, does some processing including api calls etc. In case something goes wrong in between I would like to use a afterRollbakExpression to write the file to a failed directory in t…
UPDATE: There is bug in spring-integration-aws-2.3.4
I am integrating SFTP (SftpStreamingMessageSource) as source with S3 as destination.
I have similar Spring Integration configuration:
@Bean
public S3MessageHandler.UploadMetadata…
I have spring integration application that takes data from database and converts it to JSON format…
<int-jdbc:inbound-channel-adapter query="SELECT * FROM posts" row-mapper="postMapper"
…
I am currently learning spring integration framework. So please forgive and correct me if my question is absurd.
how to or is there a way to mock an http outbound gateway to run my unit tastcase?
public IntegrationFlow sendSms() {
…
In our Spring Boot project we have the following IntegrationFlow configuration
package our.configs;
@Configuration
@EnableIntegration
public class MessageChannelsConfiguration {
public static final String OUTBOUND_CHANNEL = "outb…
I am trying to implement remote partitioning using Kafka as middle wear and getting exceptions. Just to start on this topic, started working only on master and facing problems once the master is done will work on worker side code.
Below is…
My question is related to finding a best practice to include data persistence inside an integration flow while returning the Message object so that it can be further processed by the flow.
Let’s consider the following flow:
@Bean
Integ…
We use Spring Integration in our SpringBoot project to get http response from our customer and then transform the payload to our system needed, however we found that when the payload size is over (around) 11M, the http request will always …
I am testing my integration flow with 2 different scenarios: reading an XML file and try to validate it, so in case it’s a valid XML then it should be moved to processed Dir, otherwise to Error Dir.
but when running the tests, the first on…