A rabbitmq connector that never breaks
from use_rabbitmq import RabbitMQStore
rmq = RabbitMQStore()
@rmq.listener(queue_name="test")
def test_listener(message):
print(message.body)
message.ack() # ack message
use-py/use-rabbitmq
Folders and files
| Name | Name | Last commit date | ||
|---|---|---|---|---|
Repository files navigation