pyloggr.rabbitmq package

The pyloggr.rabbitmq subpackage provides classes for publishing and consuming to/from RabbitMQ. Pika library is used, but the pika callback style has been workarounded in coroutines.


exception RabbitMQConnectionError[source]

Bases: socket.error

Exception triggered when connection to RabbitMQ fails

class RabbitMQMessage(delivery_tag, props, body, channel)[source]

Bases: object

Represents a message from RabbitMQ

Consumer.start_consuming returns a queue. Elements in the queue have RabbitMQMessage type.

ack()[source]

Acknowledge the message to RabbitMQ

nack()[source]

Acknowledge NOT the message to RabbitMQ