Currently internal. Package to simplefy the using pika.
Project description
Basic lib
Library for using rabbit mq
Sync
from easy_mq.queue import Queue
Queue.connect('url')
q = Queue('queue_name')
q.put('message')
for message in q.revivaid():
print(message)
Async
from easy_mq.queue import AsyncQueue
AsyncQueue.connect(host='url')
async def main():
q = AsyncQueue('queue_name')
q.put('message')
async for message in q.revivaid():
print(message)
import asyncio
asyncio.run(main())
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
easy_mq-0.0.4.tar.gz
(2.1 kB
view hashes)