Rabbitmq Online Tutorials

Originally developed by Rabbit Technologies Ltd. which started as a joint venture between LShift and CohesiveFT in 2007, RabbitMQ was acquired in April 2010 by SpringSource, a division of VMware. The project became part of Pivotal Software in May 2013. Which then got acquired back by VMWare in December 2019.^[7]

The project consists of:

• The RabbitMQ exchange server
• Gateways for AMQP, HTTP, STOMP, and MQTT protocols
• AMQP client libraries for Java, .NET Framework and Erlang. (AMQP clients for other languages are available from other vendors.)
• A plug-in platform for extensibility, with a predefined collection of supported plug-ins, including:
  • A "Shovel" plug-in that takes care of moving or copying (replicating) messages from one broker to another.
  • A "Federation" plug-in that enables efficient sharing of messages between brokers (at the exchange level).
  • A "Management" plug-in that enables monitoring and control of brokers and clusters of brokers.

This section gives sample programs written in Python (using the pika package) for sending and receiving messages using a queue.

Sending edit

The following code fragment establishes a connection, makes sure the recipient queue exists, then sends a message and finally closes the connection.

#!/usr/bin/env python3
import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))
channel = connection.channel()
channel.queue_declare(queue="hello")
channel.basic_publish(exchange="", routing_key="hello", body="Hello World!")
print(" [x] Sent 'Hello World!'")
connection.close()

Receiving edit

Similarly, the following program receives messages from the queue and prints them on the screen: (Note: This example does not acknowledge receipt of the message.)

#!/usr/bin/env python3
import pika

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))
channel = connection.channel()
channel.queue_declare(queue="hello")
print(" [*] Waiting for messages. To exit press Ctrl+C")
channel.basic_consume(queue="hello", on_message_callback=callback)
channel.start_consuming()

• Apache Kafka