Currently internal. Package to simplefy the using pika.
Project description
# Basic lib
Library for using rabbit mq
### Sync
```python
from easy_mq.queue import Queue
Queue.connect('url')
q = Queue('queue_name')
q.put('message')
for message in q.revivaid():
print(message)
```
### Async
```python
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())
```
Library for using rabbit mq
### Sync
```python
from easy_mq.queue import Queue
Queue.connect('url')
q = Queue('queue_name')
q.put('message')
for message in q.revivaid():
print(message)
```
### Async
```python
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.2.tar.gz
(1.9 kB
view hashes)