Home » Enterprise Java » spring » Integration

Integration

Spring Integration Custom Transformer with RabbitMQ Example

RabbitMQ is an open source message broker which implements many protocols. It can be used for point to point, request/ reply or publish-subscribe messaging patterns and is cluster deployable for high availability and throughput. The key point to remember about RabbitMQ‘s messaging model is this: The producer sends messages to an exchange, which pushes them to queues. The two important ...

Read More »

Spring Integration Http Gateway Example

1. Introduction In this post, we feature a comprehensive Example on Spring Integration Http Gateway. Messaging Gateway is an Enterprise Integration pattern that encapsulates the messaging code enabling the application to have only business logic code. In Spring Integration, the Messaging Gateway pattern is implemented in the gateway component, which is used to provide an entry / exit system between ...

Read More »

Spring Integration FTP Gateway Example

1. Introduction Spring Integration provides gateways and adapters as a means to connect to external endpoints. In his blog, Josh Long explained the difference between adapters and gateways as: An adapter receives messages from an external messaging system (JMS, e-mail, SFTP, whatever) and “adapts” it to the messaging system (as a Spring Integration Message). Once a message comes in, via ...

Read More »

Spring Integration Database Polling Example

1. Introduction Spring Integration provides JDBC channel adapters that connect a channel to a database. In the case of the inbound adapter, a database is the source on which an SQL query can be run and the complete result set is available as a message with a Java List payload. You can map the rows to a custom POJO which will ...

Read More »

Spring Integration Custom Transformer Example

1. Introduction Spring Integration provides a transformer mechanism to convert message payloads from one form to another between two channels. In this article, we will see how to implement a simple custom transformer. 2. Application The application is a Spring Boot application in which a Map is sent to a message channel. A Spring Integration Transformer listens to the message ...

Read More »

Spring Integration Splitter Example

1. Introduction Spring Integration provides many components for processing messages before they reach their end point. Splitter is the component that breaks down a message into multiple messages based on specific criteria. The benefit is that after splitting, the system can apply separate business logic on each part. For example, in an order management system, separate parts of the order ...

Read More »

Spring Integration Kafka Tutorial

1. Introduction Apache Kafka started as an internal project at LinkedIn to solve the problem of scaling up the enterprise architecture from services talking to each other with strong typing contracts to an asynchronous message-based architecture. Both message persistence and high throughput were the goals of their new system. In addition, messages were required to be acknowledged in order and ...

Read More »

Spring Integration DirectChannel Example

1. Introduction This article discusses the implementation of Spring Integration Direct Channel in a Spring Boot application. Spring Integration supports Enterprise Integration patterns, of which the message channel pattern decouples the producer and consumer endpoints and is agnostic to the message payload. A message channel provides for connectivity with various components like filters and adapters. There are good articles giving ...

Read More »

Spring Integration Chain Example

1. Introduction Spring Integration provides a way to group set of elements into one transaction and its referred as chaining. In this post we will look at MessageHandlerChain that is an implementation of MessageHandler and it can be configured as a single message endpoint while actually delegating to a chain of handlers like Filters,Transformers etc. Though the handler chain allows ...

Read More »

Spring Integration Control Bus Example

1. Introduction Control bus is a useful Spring Integration component that accepts messages on the input channel similar to Service Activator, Adapter  or Transformer but the key difference is that the payload of the message that is received indicates  an invocable action or operation on a bean. The input channel is more of an operation channel that is basically used for ...

Read More »