usepy-plugin-rabbitmq 0.1.7

No project description provided

usepy-plugin-rabbitmq

a plugin for usepy to use rabbitmq

example

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