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.
7,903
questions
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....
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() {
...
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 ...
-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 ...
-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.
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 ...
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 ...
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 ...
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 =...
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(...
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);
...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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();
...
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 ...
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. ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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://...
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....
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=&...
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 ...
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 ...
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 ...
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. ...
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(...
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 ...
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 ...
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 ...
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.
...
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
....
...
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 ...
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....
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 ...
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 ...
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 (...
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 ...
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 ...
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 ...