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.

Filter by
Sorted by
Tagged with
0 votes
0 answers
18 views

Springboot 3.1 & Spring Integration 6 - IntegrationComponentScan is not scanning MessagingGateway

Upgraded springboot from 2.7 to 3.1 and it is dependent spring jars upgraded to version 6. After this upgrade the spring integration flows are failing to process the request. Throwing error - org....
Sdubba's user avatar
  • 27
1 vote
1 answer
27 views

Outbox pattern with Spring Integration

We want to implement an Outbox pattern by using spring integration. Starting from this example, we came up with this simpeler solution: protected IntegrationFlowDefinition<?> buildFlow() { ...
user969039's user avatar
0 votes
1 answer
44 views

Error in downloading files from file server with Spring-Integration

Following the Spring guidelines, I was trying to use a SmbOutboundGateway from the spring-integration-smb library to download everything (whole structure, directory + files) at the remote file server ...
Patrick C.'s user avatar
  • 1,371
-2 votes
1 answer
44 views

Ways to implement a AWS lambda application for archiving files from file server [closed]

I would like to seek for advice on the ways to implement an AWS Lambda application (in our team's AWS account) for performing file archiving task. Objective To archive files hosted on a Windows Server ...
Patrick C.'s user avatar
  • 1,371
-2 votes
0 answers
38 views

Spring integration resources [closed]

What are some good resources to get started with spring integration. All i find are books from 2012 and the spring documentation doesn't have enough explanation for beginners.
user3691240's user avatar
0 votes
2 answers
22 views

Spring Integration SFTP fileExistsMode for mv operation

Why is not possible use FileExistsMode in case of mv operation? Is FAIL default value for mv operation? AbstractRemoteFileOutboundGateway.Command.MV .fileExistsMode(FileExistsMode.REPLACE) Why not ...
Tomek Niemczak's user avatar
0 votes
0 answers
16 views

How could I gracefully shut down a Service activator created with the kotlin suspend function in Spring Integration?

I'm trying to use Spring Integration and Kotlin Coroutine together. Functionally, it works well and I'm satisfied. However, when the Spring Integration application is stopped, the suspend function is ...
shouwn's user avatar
  • 21
0 votes
1 answer
26 views

How to implement a custom application protocol over TCP using the spring framework?

I've been trying to figure out for a while now what is the correct approach to implement a custom application protocol over TCP within the spring framework. Can you guys address me on this topic? I've ...
keyword's user avatar
0 votes
0 answers
19 views

Spring Integration - Upload file using SftpRemoteFileTemplate -- Caught an exception, leaving main loop due to Connection reset

I am using Spring Integration to upload file on remote server. It works fine but logs an exception every time. Config class @Bean fun sftpSessionFactory(): DefaultSftpSessionFactory { val factory =...
A.D's user avatar
  • 47
0 votes
0 answers
44 views

In a unit test, how to verify a function call within a Kotlin coroutine launched in the system under test?

I have a Kotlin Spring Integration TCP/IP endpoint that launches a coroutine: @MessageEndpoint class MyTcpEndpoint(private val messageProcessor: MyMessageProcessor) { @ServiceActivator(...
waldrabe's user avatar
  • 303
0 votes
1 answer
32 views

Spring Integration sftp new file not polled till message handler goes through the list of all files cached on local

@Bean public SessionFactory<SftpClient.DirEntry> sftpSessionFactory() { DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true); factory.setHost(sftpHost); ...
Shail's user avatar
  • 87
0 votes
1 answer
28 views

Using SFTP Outbound Channel Adapter to stream data to a remote file server over SFTP

In my spring boot app, I have to read a lot of data from the DB convert it to a CSV file and upload it to a SFTP server. Since the file can be huge I cannot read the whole file in memory and then ...
humbleCoder's user avatar
0 votes
2 answers
64 views

Handle deleted MQTT topics with MappingJackson2MessageConverter

In a customized IntegrationFlow, I use MappingJackson2MessageConverter for subscriptions to generate corresponding POJOs from JSON. This works perfectly so far. However, some topics are retained and ...
mrpiggi's user avatar
  • 101
0 votes
1 answer
25 views

Can same StompSessionManager instance be used for different destinations?

I have one spring integration flow with StompInboundChannelAdapter listening for incoming messages from one destination and another integration flow with StompMessageHandler for sending messages to a ...
Hernando Scheidl's user avatar
0 votes
1 answer
58 views

spring-Integration - http inbound-gateway response and asynchronous processing - task executor threads just processing one message instead of all

Description: We have a Spring Integration flow where we want to have an endpoint configured, split the payload, return to the consumer i.e. with a http code 202 and the other items must continue to be ...
ste's user avatar
  • 3
0 votes
1 answer
20 views

"A component required a bean" error for "default-output-channel" of a "header-value-router" when updating Spring Integration 5.1.3.RELEASE to 5.5.18

I'm in a process of updating Spring Boot from 2.1 to 2.5 (and eventually to 3.2), but facing an issue with Spring Integration which I'm not able to find a solution for in either Spring Integration ...
Yury K.'s user avatar
  • 561
0 votes
0 answers
46 views

Spring Integration SFTP

I’ve been running into this issue for a while now and need some assistance solving it. This error randomly presented itself: org.springframework.messaging.MessagingException: Problem occurred while ...
Andrew Johnson's user avatar
0 votes
1 answer
15 views

Spring Integration Read All Files as a Single Message

How do we read all the files from a directory as a single Message<List<File>>? The usecase is to send a status report by iterating all the files and reading their filenames as a single ...
Rayyan's user avatar
  • 119
1 vote
1 answer
16 views

Access message payload after transaction commit

I'm trying to get a better understanding of transaction management with Spring Integration and a JMS inbound. I read the docs and found other posts pertaining post-commit action for file polling, but ...
Marc Tarin's user avatar
  • 3,129
0 votes
1 answer
33 views

Send JMS Message using Spring Integration between different spring boot application

I am trying to send Jms message using spring integration from one spring boot app (master) to the other spring boot app (worker). I am using the embedded ActiveMQ as the broker. I have done the ...
of32 inc's user avatar
  • 117
1 vote
1 answer
48 views

Detect Websocket disconnection in Spring Integration

I have an Integration flow based on a WebSocketInboundChannelAdapter, configured as below. @Bean IntegrationFlow integrationFlow() { StandardWebSocketClient client = new StandardWebSocketClient(); ...
rcirne's user avatar
  • 13
0 votes
0 answers
68 views

How to catch an Exception on Spring Bean start()

I have a Spring Integration application where I use an IntegrationFlowContext to manage my integration flows. They need to be started, stopped and restarted dynamically through an exposed endpoint. My ...
rcirne's user avatar
  • 13
1 vote
1 answer
20 views

How to pool multiple directories using spring integration instead of creating separate file inbound adaptor? Is there any dynamic way of creating this

How to create spring integration for more than 10 directories? In my case currently we are having 2 location to pool, which is easy that we can create 2 different file inbound adaptor per directory. ...
NareshKumar S's user avatar
0 votes
2 answers
25 views

Tcp inbound gateway does not call the Serilaizer but deserializer is getting called

We need to listen to the port and receive the message and then we need to write it back in the same output stream. we have written custom deserializer which is working fine. but custom serilaizer is ...
Piratheepan's user avatar
0 votes
1 answer
14 views

Spring Integration - Rollback on JMS MessageDrivenChannelAdapter without log pollution

I'm using Spring Integration (with Java DSL) to consume messages from JMS (MQ and Solace). In some cases, my flow throws an exception and I'd like the message to be rolled back to transport and ...
Yaneek's user avatar
  • 13
0 votes
1 answer
90 views

Create topic in KafkaContainer for Integration Test

I'm trying to create a topic in my KafkaContainer using @ServiceConnection - when running the application I get an error message when I'm trying to produce to the topic saying Topic myTopic not ...
Beez's user avatar
  • 31
0 votes
1 answer
30 views

File monitoring and processing using spring batch integration

I am currently learning spring-batch-integration, and for that purpose I wanted to create an application that monitor a txt file in a specified directory, then if the file exists launch a batch job ...
of32 inc's user avatar
  • 117
0 votes
1 answer
56 views

Queries on poller in spring Integration

I am new to spring integration and pretty much all the things stated below. I have a inboundChannelAdapter to pull messages from a subscription in pubsub. As it is, it's pulling messages from the ...
Mentee's user avatar
  • 1
0 votes
1 answer
26 views

Create a flow with IntegrationFlow that's close after certain time if no messages are sends

I'm building a system that's create flows dynamically, but sometimes messages stop being received. So i wanna make a logic that stop the flow to receive messages or, if it is possible, destroy the ...
Eduardo B.'s user avatar
0 votes
1 answer
18 views

How to change request method from POST to GET and extract from body request param using spring integration?

I have a running api which expects prop as parameter. The task that I would like to solve is to create a proxy using spring integration which accepts post request with body. For example: POST http://...
Farkhad L.'s user avatar
0 votes
0 answers
19 views

Not able to establish a connection between Spring Integration with ActiveMQ using AMQP

while connecting Spring Integration with ActiveMQ using AMQP, getting an error at the time of creating JMSConnectionFactory. Exception is below. org.springframework.jms.listener....
Ganesh Ghorui's user avatar
1 vote
1 answer
63 views

How to use SFTP Spring Integration mput with SftpOutboundGateway when File object is directory?

<int-sftp:outbound-gateway session-factory="sftpSessionFactory" use-temporary-file-name="false" request-channel=&...
Tomek Niemczak's user avatar
0 votes
1 answer
33 views

How to create backpressure mitigation using rabbitmq as buffer in spring integration?

I have an api which is running on http://localhost:9999/greet/v3/api (API A) which responds to requests with 2 seconds delay (simulated). And I have created following integration flow to proxy all ...
Farkhad L.'s user avatar
0 votes
1 answer
16 views

Spring Integration Message Channel - Memory Based or File Based

I want to evaluate whether spring integration suits our current requirement or not. We will receive an input stream which contains 1 million transactions (Let us Consider A in the below code is one ...
user1862354's user avatar
0 votes
1 answer
51 views

Spring Integration Deserializer not fetching the Entire Message through TCP

We are using the Spring Integration Flow to connect to the Tcp Port and fetch the Message. Find Below the Code for the Same. @Bean public IntegrationFlow integrationFlow() { return ...
Piratheepan's user avatar
0 votes
1 answer
52 views

Smb Outbound channel not transfering files

I have a service that takes a file and sends it to a SMB Messaging Gateway using Spring Integration. I created a directoryResolverService to handle determine remotedirectory path based on file sent. ...
digioflow's user avatar
0 votes
0 answers
45 views

Test Logging Statements in an error handler

I created a custom error logger based on the type of MessagingException is thrown during process based on what the InstanceOf is in the payload. @ServiceActivator public void handleThrowable(...
Beez's user avatar
  • 31
0 votes
1 answer
38 views

Spring Integration - get warning logs for inbound-gateway response then continue with asynchronous processing in background

Description: We have a Spring Integration flow where we want to have an endpoint configured, split the payload, perform some transformation in parallel and then after some validation one part return ...
ste's user avatar
  • 3
0 votes
0 answers
36 views

Parallelism within a channel message group

I'm investigating the use of Spring Integration to implement the transactional outbox pattern. I found a transactional outbox sample. If my application needs multiple outboxes, I believe I need to use ...
Martin Kamp Jensen's user avatar
0 votes
1 answer
19 views

Spring Integration: Error handling for Jpa Outbound Adapter

i have a Spring Integration flow that uses Jpa.inboundAdapter() as a source, manipulates the read entities in transform and finally stores them again using Jpa.outboundAdapter. However, during ...
Christoph Dahlen's user avatar
0 votes
1 answer
41 views

Spring Integration error: Failure to write to 'foo/002.txt.writing' while uploading the file

I'm experimenting with the following sample setup from SI samples to understand its inner workings with a goal to then adapt it to similar set of tasks in upper environments. ...
Simeon Leyzerzon's user avatar
1 vote
1 answer
336 views

Spring Integration SFTP connection fails - Unable to negotiate key exchange for kex algorithms

I am using Spring Integration (Version: 6.1.2) to connect to an SFTP server. While creating an SFTPSession, I get this exception - java.lang.IllegalStateException: failed to create SFTP Session .... ...
Do Will's user avatar
  • 851
1 vote
1 answer
39 views

Spring Integration file splitting sample doesn't react to content coming into inbound adapter channel

I'm testing out the following sample setup from SI samples to understand and then adapt it to the similar set of tasks. I won't need mailing functionality, but the rest of it seems adaptable enough ...
Simeon Leyzerzon's user avatar
1 vote
1 answer
196 views

Tracing in Spring Integration (Spring boot 3.0.9)

I'm trying to use Spring integration: I receive a message via JMS and send it to Kafka: @Override protected IntegrationFlowDefinition<?> buildFlow() { return from(Jms....
Roman's user avatar
  • 127
0 votes
1 answer
47 views

Scaling Spring Batch remote partitioning with kafka

I need to scale spring batch job by remote partitioning with kafka. I want to run manager step on one VM and worker steps on different VMs. For that I have some questions - If my manager VM instance ...
ashok's user avatar
  • 3
0 votes
1 answer
26 views

Spring Integration New Transactional Scope within File Poller Transaction

We have a file poller flow bounded by pseudoTransactionManager to move / delete the input file at the end of the processing based on success or failure. While this huge file is processed, we would ...
Rayyan's user avatar
  • 119
1 vote
0 answers
73 views

Spring Integration for Report orchestration workflow

Problem statement: I primarily work on Spring Boot and just started reading about Spring Integration for the below problem statement I need to develop a spring integration project which talks to 10 (...
cyberman123's user avatar
1 vote
1 answer
36 views

Multiple ThreadStatePropagationChannelInterceptors not possible

I have a Spring Integration setup where I have configured a SecurityContextPropagationChannelInterceptor which propagates the spring security context async channel boundaries. This works well. I also ...
Piers Geyman's user avatar
0 votes
1 answer
19 views

How to add retry advice to kafka publishing IntegrationFlow

I'm trying to setup retryAdvice if there is an error in publishing to kafka in my publisherFlow. I can't seem to find the correct configuration on how to get it working. Any help or guidance would be ...
Beez's user avatar
  • 31
0 votes
2 answers
62 views

How to process messages parallel in spring integration in multiple processes while they must be processed sequential on a correlation id

A cluster with multiple processes must process messages sequential on receive time for the same correlation id. For different correlation ids they must be processed parallel. How to solve this with ...
wdk's user avatar
  • 373

1
2 3 4 5
159