A Python library for interacting with RabbitMQ - message broker

How to run Python

broker = RabbitmqController(host='...', port=..., username='...', password='...', heartbeat=...)

broker.declare_queues(names=['...',], arguments=...)

def callback(ch, method, properties, body):
    data = body
    broker.accept(method=method)
    broker.reject(method=method, body=body)


broker.listen(prefetch_count=1, queue='...', callback=callback)
broker.send(queue='...', body=data)
broker.close()

Structure :

├── rabbitmq_controller.py
├── requirements.txt