RabbitMQ – Message Broker

Module 1: Message Broker Fundamentals

• Why async messaging: decoupling and resilience
• AMQP protocol: producer, exchange, queue, consumer
• RabbitMQ vs Apache Kafka vs IBM MQ
• RabbitMQ installation: Docker and Linux
• Management UI: queues, exchanges, bindings
• Connection, channel, and virtual host concepts

Module 2: Exchanges & Bindings

• Direct exchange: routing by exact routing key
• Fanout exchange: broadcast to all queues
• Topic exchange: wildcard routing key matching
• Headers exchange: header-based routing
• Default exchange and implicit binding
• Dead letter exchange configuration

Module 3: Message Patterns

• Work queue pattern: task distribution
• Pub/sub with fanout exchange
• Topic-based routing for selective subscriptions
• RPC pattern: correlation ID and reply-to
• Message acknowledgement: auto and manual ack
• Negative acknowledgement: nack and reject

Module 4: Java AMQP Client

• RabbitMQ Java Client library setup
• ConnectionFactory: credentials and vhost
• Channel: queue declare, exchange declare, bind
• BasicPublish: message properties and routing
• BasicConsume: DeliverCallback and consumer tags
• QoS prefetch: consumer throttling

Module 5: Reliability & Durability

• Durable queues and persistent messages
• Publisher confirms: ack and nack
• Dead letter queues for failed messages
• Message TTL: per-message and per-queue
• Lazy queues: disk-backed for large queues
• Quorum queues for HA

Module 6: RabbitMQ Clustering

• Cluster formation: peer discovery methods
• Queue mirroring: classic mirrored queues
• Quorum queues: Raft-based replication
• Federation for cross-site messaging
• Shovel plugin for message forwarding
• Network partitions and partition handling

Module 7: Spring AMQP & Framework Integration

• Spring AMQP: RabbitTemplate and listener containers
• @RabbitListener annotation
• Message converters: JSON and Java serialisation
• Spring Retry for consumer error handling
• Async message processing patterns
• Testing with embedded RabbitMQ

Module 8: Operations & Cloud

• RabbitMQ monitoring: Prometheus and Grafana
• Alerts: queue depth, consumer count, memory
• CloudAMQP: managed RabbitMQ
• Security: TLS, vhost isolation, user permissions
• Performance tuning: prefetch and concurrency
• RabbitMQ in microservices architecture patterns

Our Apache orchestration instructors are data engineering leads who have deployed Airflow in production for data pipeline orchestration and RabbitMQ for microservices messaging at technology companies and financial institutions. They combine workflow automation knowledge with practical messaging architecture experience.