No project description provided
Project description
use-rabbitmq
A rabbitmq connector that never breaks
example
from use_rabbitmq import useRabbitMQ
rmq = useRabbitMQ()
@rmq.listener(queue_name="test")
def test_listener(channel, deliver, properties, body):
print(body)
channel.basic_ack(deliver.delivery_tag) # 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.9a0.tar.gz
(3.2 kB
view hashes)
Built Distribution
Close
Hashes for use_rabbitmq-0.1.9a0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | a2a13904ee8e485365970f9ae3ca2331add076b1c9f4e409142e16a93605c00d |
|
MD5 | b58a86dcbe0c456b5a075e08f71322ce |
|
BLAKE2b-256 | 898166126a9afd93ea4b0b67af8efd19a34e546ed79ef0cacc13eba367b9d37f |