Apache Camel #3 - RabbitMq

Hello there again!

It passed 2 months since my last article, so I decided to write a new one.

Today we will focus on RabbitMq and what we can do with it using Camel.

Dependencies

Maven repository -> Camel RabbitMq

Connection to RabbitMq

When using SpringBoot:

1. Create a class with @Configuration annotation.
2. Create a method which will return ConnectionFactory and annotate it with @Bean.
3. Instance a connection factory and set properties.

@Bean public ConnectionFactory rabbitConnectionFactory() { ConnectionFactory connectionFactory = new ConnectionFactory(); connectionFactory.setHost("localhost); connectionFactory.setPort(5672); connectionFactory.setUsername("Username"); connectionFactory.setPassword("Password); return connectionFactory; } 

*note: You can use application properties to connect to the server.

If you are using pure Camel:

Using RabbitMq

Now that we successfully connected to RabbitMq it's time to start consuming/producing messages to queue/exchange.

Camel RabbitMq component documentation.

Consuming Message from the queue:

1. We will set the rabbitMq component to fetch from the queue which is bind to exchange.
2. Log message body received.

public void configure() {

from("rabbitmq:exchangeA?queue=QueueA&declare=true") .routeId("RabbiqMqConsumer") .log("Message received: ${body}"); 

Producing Message to exchange:

1. We will create a route.
2. Set message body.
3. Send a message to the exchange.

public void configure() {

 from("timer:fooo?period=10000") .routeId("RabbiqMqProducer) .setBody().constant("{\"foo\":\"bar\"}") .log("Message to be sent: ${body}") .to("rabbitmq:exchangeB"); 

Aand that's all folks, if anyone have some question, feel free to ask me via DM or just leave a comment.