Python RabbitMQ client
Basic RabbitMQ Python connector.
eea.rabbitmq.client is a connector for a RabbitMQ server.
Usage example:
from eea.rabbitmq.client import RabbitMQConnector rabbit_config = { 'rabbit_host': "10.0.0.1", 'rabbit_port': "8080", 'rabbit_username': "admin", 'rabbit_password': "admin" } queue_name = "QUEUE_NAME" rabbit = RabbitMQConnector(**rabbit_config) rabbit.open_connection() rabbit.declare_queue(queue_name) rabbit.send_message(queue_name, "body text") rabbit.close_connection()
RabbitMQ messages are bytes, though they may optionally have an encoding flag. When consuming messages, in Python 3, they are received as bytes, and should be decoded:
method, properties, body = rabbit.get_message(queue_name) message = body.decode(properties.content_encoding or 'ascii')