Skip to main content
8,109 questions
Newest Active Bountied Unanswered
Filter by
Sorted by
Tagged with
Advice
0 votes
2 replies
36 views

Continue learning IntegrationFlows. Question of the day. How to properly use .handle(MyCustomPojo.class, (message, payload) -> ...)? I have defined a MyCustomPojo with lombok's NoArgs/AllArgs and ...
Draaksward's user avatar
  • 831
Advice
1 vote
1 replies
62 views

I'm trying to understand how to properly define routes for Spring's IntegrationFlows. I have a MQTT source, which is implemented as a MqttPahoMessageDrivenChannelAdapter. From there I receive messages ...
Draaksward's user avatar
  • 831
2 votes
1 answer
126 views

After upgrading Spring Boot from 2.7 to 3.4, receiving message from TCP server to our service is getting changed with different code. For example, previously the received message is 1784 after ...
mannam jayanth's user avatar
  • 22
3 votes
1 answer
148 views

I have a service that polls a database within a transaction, always removing the record and if an exception is thrown during processing adds a new record incrementing the 'try count' for that entry. ...
D-Dᴙum's user avatar
  • 7,981
0 votes
0 answers
40 views

I have a high volume of messages being put on a QueueChannel. Each Object will have multiple updates (different hashCode, same equals(), different attribute values) that are written in time-event ...
lafual's user avatar
  • 835
0 votes
1 answer
90 views

I'm implementing Spring Batch remote partitioning with Spring Integration and Kafka as a middleware. Worker replies successfully arrive at the managerInboundReplies channel (confirmed via interceptor ...
Himanshu Dalal's user avatar
  • 1
3 votes
1 answer
67 views

I am using Spring Integration to implement the Transactional Outbox Pattern. I have code like this: @Bean IntegrationFlow eventFlow( JdbcChannelMessageStore jdbcChannelMessageStore, ...
Wim Deblauwe's user avatar
  • 27.2k
2 votes
1 answer
50 views

Currently I'm in the process of porting an previously working application which consumes ServerSentEvents (SSE) using Spring Integration WebFlux from Java to Kotlin. The former worked in Java using ...
Dennis Nijssen's user avatar
  • 197
2 votes
1 answer
62 views

I have built a Spring Cloud Function application with a Spring Integration flow exposed as a function (actually, an imperative Consumer) and a reactive Function. Both functions are composed and ...
rmarianni's user avatar
  • 45
1 vote
0 answers
77 views

I'm having an issue that I'm unable to solve it. Here is the following scenario In my application I'm creating an Entity and then I send that entity as XML in in a Queue. Then I'm having an outound-...
Med Akrem Lakhdhar's user avatar
  • 11
0 votes
0 answers
40 views

I have problem with trylock() in Spring Integration framework, when slow sql procedure is executing. I have 2 instances of Spring Boot microservices. My flow: schedule poller by Pollers.cron -> ...
Tomek Niemczak's user avatar
  • 31
1 vote
1 answer
64 views

The title could be a little misleading because @Fallback annotation exists. And what I am asking is similar to this related question but requires bean names. Let's start with the... Context I have a ...
usr-local-ΕΨΗΕΛΩΝ's user avatar
  • 27.1k
0 votes
1 answer
60 views

Question: I’m building a Spring Boot application that uses Spring Cloud Stream with the RabbitMQ binder. My project pulls in several dependencies—Spring MVC, Spring Cloud Stream, Resilience4j (circuit ...
CursedChico's user avatar
  • 571
0 votes
1 answer
50 views

I want to read from 4 database tables using JDBC Inbound Adapters with polling. Each JDBC Inbound Adapter serves as the starting point of one of my 4 integration flows. Each flow is independent of the ...
gingersa's user avatar
  • 3
0 votes
1 answer
43 views

I have a SpringBoot application using version 3.4.1 and also Spring Integration 6.4.1. I am creating WebSockets dynamically, upon an HTTP request, to which I send messages from different threads. The ...
Andrei Roșu-Cojocaru's user avatar
  • 509
2 votes
1 answer
68 views

I have a spring integration microservice which has an integration flow starting from an Jdbc Inbound Channel adapter. When using JDBC inbound channel adapter in an integration flow, we can set an ...
Chandula's user avatar
  • 95
1 vote
1 answer
50 views

I have a spring integration flow which listens to JMS messages using the Java DSL through the use of a JMS messageDrivenChannelAdapter. It has a subflow as follows: f -> f.handle(ServiceA) ....
Chandula's user avatar
  • 95
1 vote
1 answer
36 views

We are using Spring Integration Flows in a project to create an api out of incoming kafka events. While using these flows certain patterns have emerged in how we use them. To keep our code short and ...
Marten Leckebusch's user avatar
  • 13
1 vote
1 answer
24 views

I have a org.springframework.integration.dsl.IntegrationFlow @Bean public IntegrationFlow publishData() { return IntegrationFlows.from(PUBLISH_DATA).enrichHeaders((h) -> { h.header(...
Ivan Karotki's user avatar
  • 355
2 votes
1 answer
62 views

I currently have a flow with a splitter and an aggregator that uses a gateway to call another complex flow with asynchronous subflows. Currently I have the gateway configured with a replyTimeout set ...
Piers Geyman's user avatar
  • 612
2 votes
1 answer
71 views

I recently upgraded a project from Spring Integration 5.x to 6.4.4. Everything is working other than one flow setup that is failing and it is hard to see why. (It was working fine before). It is quite ...
Piers Geyman's user avatar
  • 612
0 votes
2 answers
41 views

In my setup, my IntegrationFlow is configured as follows, but the message is stuck at queueChannel1 without flowing to queueChannel2. Do you know any missing steps that I may have ? message -> ...
user20745683's user avatar
  • 41
1 vote
1 answer
362 views

We are currently working on a Spring Integration flow where each incoming message needs to trigger a call to an external HTTP service. The external call can take up to 20 seconds to complete, and the ...
Timo B.'s user avatar
  • 13
1 vote
1 answer
58 views

Lets assume the following scenerio: Caller ->Gateway -> Bridge -> Aggregator--- ===== output -> TCP ...
Shirshak55's user avatar
  • 560
0 votes
1 answer
84 views

I'm experiencing an issue with how my Spring Boot application (using Spring Integration) handles TCP connections in a Kubernetes environment. My setup includes an NLB (Network Load Balancer) in front ...
user30203336's user avatar
  • 1
2 votes
1 answer
40 views

https://github.com/spring-projects/spring-integration/blob/fe5b12d98bc98ff03a27ae95a72a2768ab3795a2/spring-integration-core/src/main/java/org/springframework/integration/handler/support/...
Harika penumatsa's user avatar
  • 21
0 votes
0 answers
71 views

I am using Spring Boot Version - 3.2.4. I have an API service that runs on 2 instances, that API creates an order in the system. I am using Spring Boot Integration for JDBC locking. But in some ...
Chitransh Agarwal's user avatar
  • 83
0 votes
1 answer
45 views

Below code is only copying the files from the (windows shared drive)remote directory but all the sub directories of remote directory are skipped. I don't understand why the sub directories are skipped....
siva's user avatar
  • 75
1 vote
1 answer
53 views

Whenever my tcp client is down, I get these errors. How do I silence it? I don't see it going to errorChannel for some reason. ERROR [main][org.springframework.integration.ip.tcp....
tofu's user avatar
  • 11
0 votes
1 answer
48 views

I'm upgrading from Spring Boot 2.7 to Spring Boot 3.3 Publisher(another app) publishes to exchange migration.rxi to queue migration.wq to exchange migration.rxo to queue migration.q Mine is spring ...
Harshit Bansal's user avatar
  • 71
1 vote
2 answers
238 views

A Java spring boot micro-service is required to consume messages from an IBM point-to-point message queue. After processing some transformations and enrichments, the resultant messages need to be sent ...
dGayand's user avatar
  • 711
1 vote
2 answers
161 views

I have a requirement where I have to read a message from an IBM MQ queue and then publish it to 3 different queues after performing different transformations for each. Is it possible to handle this in ...
Chandula's user avatar
  • 95
1 vote
1 answer
66 views

[Problem] We are facing an issue where a connection created in one thread is being shared with another thread when a new request comes in. This happens even though each request should have its own ...
aileen's user avatar
  • 11
2 votes
1 answer
88 views

Some year ago, we switched from some self built leader election mechanism to spring integration leader election, both on MariaDB clusters, relying on duplicate key violation. We switched to spring ...
mangiari's user avatar
  • 21
1 vote
1 answer
54 views

I have a spring integration flow that does polling with JdbcPollingChannelAdapter, like this: IntegrationFlow.from(buildJdbcMessageSource(), c -> c.poller(...
Thiago Sayão's user avatar
  • 2,397
1 vote
1 answer
38 views

I'm trying to get KinesisMessageDrivenChannelAdapter exposed on JMX so that I get access to operations that manipulate the checkpoints (resetCheckpointForShardToSequenceNumber etc.). But all I can see ...
Tomek Bielecki's user avatar
  • 11
0 votes
0 answers
114 views

I have figured out how to implement observability with spring boot, micrometer and open telemetry. It al works fine only we have some services build with spring integration for pulling a message from ...
Remco Cats's user avatar
  • 13
1 vote
1 answer
91 views

I'm implementing a TCP client in Spring Integration with multiple socket connections and facing an issue with keeping all the connections alive. Current Implementation I've set up multiple cached TCP ...
양지수's user avatar
  • 11
0 votes
1 answer
42 views

In my project I have used DirectChannel bean ,its working perfectly .But the new requirement is doing Async sftp upload parallelly using ExecutorChannel .. But files are not getting transfered . @...
Ajitesh Mandal's user avatar
  • 1
1 vote
1 answer
33 views

When I create an IntegrationFlow setting the sendTimeout() value on SourcePollingChannelAdapterSpec is being ignored causing the polling thread to block. This does not happen if I create a ...
D-Dᴙum's user avatar
  • 7,981
1 vote
1 answer
45 views

My application has to download files from a remote file server in regular time intervals. My implementation is based on Spring Integration SMB and generally works as expected (see the listing below). ...
mrnst's user avatar
  • 55
2 votes
1 answer
108 views

I'm trying to implement a Spring Integration Flow transferring files from a local file system to a remote file system using Spring Integration's SMB support. My Spring Boot configuration is as follows:...
mrnst's user avatar
  • 55
1 vote
1 answer
232 views

As part of the learning curve, I am trying to publish a message to Mosquitto MQTT using Spring Integrations. I've set up a config (mostly from parts I found by googling, but the Listener part works ...
Draaksward's user avatar
  • 831
0 votes
1 answer
86 views

I'm using SpringBoot3.2 and SpringIntegration6 for supporting MQTT messages, I have defined a public Maven module named sz-common-mqtt, and the effect I want to achieve is that any other module that ...
liang li's user avatar
  • 133
0 votes
1 answer
41 views

I would like to create an asynchrone flow. My main flow "jiraVersionWebhook" will return a response quickly, and with a wiretap I will execute long process with split and another component. ...
Médéric Martin's user avatar
  • 99
0 votes
1 answer
28 views

Is it possible to attach a TransactionSynchronizationFactory to an outbound JMS Outbound Adapter? We are trying to send a message to a JMS queue and want to update a database once the JMS send is ...
VPN236's user avatar
  • 27
0 votes
1 answer
46 views

We want to commit JMS read transactions based on a property in the middle of our flow. Our implementation currently uses an executor to achieve this. @Bean public Consumer<...
VPN236's user avatar
  • 27
1 vote
1 answer
110 views

I try to write some files on a SMB share using Spring Integration SMB. I have the following configuration: @Configuration public class SambaConfiguration { @Value("${samba.host}") ...
LeGaulois88's user avatar
  • 99
2 votes
1 answer
83 views

I have a scenario where multiple integration flows (e.g., listening to JMS queues) are created during app runtime via IntegrationFlowContext and it works fine (SpringBoot 3.4.0), however we noticed ...
A. Diniz's user avatar
  • 338
0 votes
1 answer
93 views

We are using Spring Integration 6.3.3 Aggregator pattern, with JDBCMessageStore, and expiry timeout. We want to also send the partial group on expiry, which we consider as an error condition. We want ...
Shinta Smith's user avatar
  • 509

1
2 3 4 5
…
163