use-rabbitmq 0.1.7

No project description provided

use-rabbitmq

a plugin for usepy to use rabbitmq

example

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()