use-rabbitmq

A rabbitmq connector that never breaks

example

from use_rabbitmq import RabbitMQStore

rmq = RabbitMQStore()


@rmq.listener(queue_name="test")
def test_listener(message):
    print(message.body)
    message.ack()  # ack message