JavaRabbitMQ

This project demonstrates a simple publisher-consumer pattern using Java, Spring Boot, and RabbitMQ.

• RabbitMQ via docker

docker run --rm -it --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:4.1.4-management

Projects

rabbitmq_publisher

• Purpose: A Spring Boot web application that acts as a message publisher.
• Technology: Java 17, Spring Boot, Maven.
• Functionality: Exposes a REST endpoint at /orders. When it receives a POST request with a product name and an order type (standard or premium), it creates an Order object and sends it to the appropriate queue (standard-order-queue or premium-order-queue) in RabbitMQ using a direct exchange.
• Key Libraries: spring-boot-starter-web, spring-boot-starter-amqp, lombok.

rabbitmq_consumer

• Purpose: A Spring Boot application that acts as a message consumer.
• Technology: Java 17, Spring Boot, Maven.
• Functionality: Listens to both the standard-order-queue and premium-order-queue on RabbitMQ. When a message arrives, it deserializes the Order object and prints it to the console, indicating whether it's a standard or premium order.
• Key Libraries: spring-boot-starter-amqp, lombok.

Build and Run

Navigate into each project's directory to build and run them.

Build

First, build the JAR files for both projects using Maven.

# From the root directory
(cd rabbitmq_publisher && mvn clean package)
(cd rabbitmq_consumer && mvn clean package)

Run

After building, you can run the applications.

1. Run the Consumer

java -jar rabbitmq_consumer/target/rabbitmq_consumer-0.0.1-SNAPSHOT.jar

2. Run the Publisher (Defaults to port 8080)

java -jar rabbitmq_publisher/target/rabbitmq_publisher-0.0.1-SNAPSHOT.jar

Usage

Once both applications are running, you can send a POST request to the publisher to create an order, which will then be consumed and logged by the consumer.

Standard Order

curl -X POST -H "Content-Type: application/json" -d '{"orderType": "standard", "product": "MyStandardProduct"}' http://localhost:8080/orders

Premium Order

curl -X POST -H "Content-Type: application/json" -d '{"orderType": "premium", "product": "MyPremiumProduct"}' http://localhost:8080/orders