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.

Spring Integration provides an extension of the Spring programming model to support the well-known Enterprise Integration Patterns. Spring Integration enables lightweight messaging within Spring-based applications and supports integration with external systems via declarative adapters. Those adapters provide a higher-level of abstraction over Spring's support for remoting, messaging, and scheduling.

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. For example "How do I integrate Spring MVC with Struts?" would not be an appropriate question for this tag. Whereas "How do I solve such-and-such issue with the Spring Integration xyz channel adapter?", or "How can I use Spring Integration to communicate with [some legacy system]?" would be appropriate.

Resources

See Also

7860 questions
169
votes
11 answers

When to use Spring Integration vs. Camel?

As a seasoned Spring user I was assuming that Spring Integration would make the most sense in a recent project requiring some (JMS) messaging capabilities (more details). After some days working with Spring Integration it still feels like a lot of…
ngeek
  • 7,733
  • 11
  • 36
  • 42
127
votes
17 answers

Spring AMQP + RabbitMQ 3.3.5 ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN

I am getting below exception org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker…
Javaboy
  • 2,044
  • 2
  • 20
  • 24
60
votes
2 answers

Spring-Kafka vs. Spring-Cloud-Stream (Kafka)

Using Kafka as a messaging system in a microservice architecture what are the benefits of using spring-kafka vs. spring-cloud-stream + spring-cloud-starter-stream-kafka ? The spring cloud stream framework supports more messaging systems and has…
35
votes
2 answers

Spring MVC 3.2.8: FtpInboundFileSynchronizer

I have an application based on Spring Web model-view-controller (Spring MVC 3.2.8 ) and I want to use the integration with FTP using the default implementation of FTP SessionFactory. I have this piece of code private void performImport() throws…
La Carbonell
  • 1,976
  • 5
  • 22
  • 52
35
votes
5 answers

Using a request scoped bean outside of an actual web request

I have a web application that has a Spring Integration logic running with it in a separated thread. The problem is that at some point my Spring Integration logic tries to use a request scoped bean and then i get the following errors: Caused by:…
Diego Urenia
  • 1,620
  • 2
  • 21
  • 28
24
votes
3 answers

What is the difference between Gateway and Service Activator?

What is the difference between Gateway and Service Activator as Message Endpoints (in terms of Enterprise Integration Patterns)?
Belun
  • 4,151
  • 7
  • 34
  • 51
22
votes
1 answer

How to create a Tcp Connection in spring boot to accept connections?

I have been through this and understood that I need to create a TcpReceivingChannelAdapter to accept connections. But I don't know how to proceed with that. Could someone guide me over this?
amitection
  • 2,696
  • 8
  • 25
  • 46
21
votes
2 answers

Send and receive files from FTP in Spring Boot

I'm new to Spring Framework and, indeed, I'm learning and using Spring Boot. Recently, in the app I'm developing, I made Quartz Scheduler work, and now I want to make Spring Integration work there: FTP connection to a server to write and read files…
joninx
  • 1,775
  • 6
  • 31
  • 59
21
votes
2 answers

Spring Integration - Inbound vs Outbound Channel Adapters

What is the fundamental difference between inbound and outbound channel adapters? Any examples would be very helpful. I have reviewed the Spring docs and this "directional" distinction is not clear to me. I support an application that has an…
19
votes
1 answer

Controller mapping are not logging at startup

I have a requirement to upgrade the existing code which runs on jdk 8 to jdk 11 After upgrading it the controller mappings are not showing up during startup.In this application we have defined some inbound gateways for integration and we have also…
Sid
  • 255
  • 2
  • 12
19
votes
1 answer

How to create a Spring Reactor Flux from a ActiveMQ queue?

I am experimenting with the Spring Reactor 3 components and Spring Integration to create a reactive stream (Flux) from a JMS queue. I am attempting to create a reactive stream (Spring Reactor 3 Flux) from a JMS queue (ActiveMQ using Spring…
19
votes
2 answers

How can I use Spring Boot auto-configured beans in XML configuration files?

I'd like to take advantage of some of the Spring Boot auto-configured beans in XML configuration files, but I keep running into exceptions and errors when I try to do so. For example, if I have data-related libraries on my class path, Spring Boot…
ccampo
  • 1,483
  • 3
  • 12
  • 14
18
votes
5 answers

Spring Kafka - How to reset offset to latest with a group id?

I am currently using Spring Integration Kafka to make real-time statistics. Though, the group name makes Kafka search all the previous values the listener didn't read. @Value("${kafka.consumer.group.id}") private String…
bachrc
  • 1,106
  • 1
  • 12
  • 20
18
votes
8 answers

How to monitor folder/directory in spring?

I wan't to write Spring Boot Application in spring which will be monitoring directory in windows, and when I change sub folder or add new one or delete existing one I wanna get information about that. How can i do that? I have read this…
amkz
  • 568
  • 3
  • 9
  • 31
18
votes
1 answer

Cluster-wide singleton in Websphere Cluster

I need to run a component using Apache Camel (or Spring Integration) under WAS ND 8.0 cluster. They both run some threads on startup, and stop them on shutdown normally. No problem to supply WAS managed threadpool. But that threads must run on…
1
2 3
99 100