This project holds some code samples, snippets, tests and documentation for the Spring AMQP library.
The tests in this project require a locally running Rabbit MQ broker. The easiest way to set it up is using a Docker container. Once you have Docker running on your machine, use the following commands to run Rabbit MQ in Docker:
rmq_container_id=$(docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq) && sleep 5 && docker exec $rmq_container_id rabbitmq-plugins enable rabbitmq_managementTo make the examples easier to be run separately, each is written as a test within the src/test/java directory.
| Example | Description |
|---|---|
| Simple send and receive | A very basic example to send an receive messages with RabbitTemplate |
| Spring Message Class | Using the Spring Message abstraction to send and receive messages |
| Direct Exchange with Configuration and Listener | Using a Direct Exchange with Spring @Configuration and a Message Listener |
| Direct Exchange with multiple Listeners | Using a Direct Exchange with multiple Message Listeners |
| Direct Exchange with a annotated Listener | Using a Direct Exchange with the @RabbitListener annotation |
| Fanout Exchange with Configuration and Listener | Using a Fanout Exchange with Spring @Configuration and a Message Listener |
| Fanout Exchange with multiple Listeners | Using a Fanout Exchange with multiple Message Listeners |
| Topic Exchange with multiple Listeners | Using a Topic Exchange with multiple listeners |
| Publisher Confirm | Using Publisher Confirms with multiple listeners |
In order to use the @RabbitListener annotation, use the @EnableRabbit annotation in your @Configuration and make sure to define a SimpleRabbitListenerContainerFactory bean:
@Configuration
@EnableRabbit
public class RabbitConfiguration {
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory() {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
return factory;
}
@Bean
public AnnotationBasedMessageListener annotationBasedMessageListener() {
return new AnnotationBasedMessageListener();
}
}
@Component
public class AnnotationBasedMessageListener {
@RabbitListener(queues = "annotation-based-queue")
public void onMessage(Message message) {
// ...
}
}