No project description provided
Project description
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()
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
use_rabbitmq-0.1.7.tar.gz
(2.8 kB
view hashes)
Built Distribution
Close
Hashes for use_rabbitmq-0.1.7-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | c07c690c7fbcd79e94cc6ef4bc86e43e4095396ae9c2666034e322d9d12d9530 |
|
MD5 | b89dc7e501a91e94a9fc40ef112fc390 |
|
BLAKE2b-256 | a1cdb4587bfc72f88fd474e6aba73bab397735d797d342adb3446a9e88f15eea |