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(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.2.1.tar.gz
(3.0 kB
view hashes)
Built Distribution
Close
Hashes for use_rabbitmq-0.2.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4ad52d1d810fd27b77741f114c2bcbe979d6528358a1ef2a8cca247c6883fdb0 |
|
MD5 | 6ee0d5e651e9643590bd023cce0dbaf9 |
|
BLAKE2b-256 | 328aba7fb6648e51ebdc35166675827d8e539fac67255f103f62b4e668cfb586 |