A rabbitmq connector that never breaks
from use_rabbitmq import useRabbitMQ
rmq = useRabbitMQ()
@rmq.listener(queue_name="test")
def test_listener(message):
print(message.body)
message.ack() # ack message
if you use it with usepy, you can use it like this:
from usepy.plugin import useRabbitMQ
rmq = useRabbitMQ()