Queue-Manager 0.0.1

A library for using queues as both a producer and a consumer

Riftool Queue Manager

QueueConsumer Example

from queue_manager import QueueConsumer
with QueueConsumer(amqp_url='http://queue/url', exchange_name='logs') as consumer:
    consumer.start_consuming()

QueueProducer Example

from queue_manager import QueueProducer
with QueueProducer(amqp_url='http://queue/url', exchange_name='logs', queue_arguments={}) as producer:
    producer.publish(priority=10, message='Message')