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.7.tar.gz
(2.1 kB
view details)
Built Distribution
File details
Details for the file easy_mq-0.0.7.tar.gz
.
File metadata
- Download URL: easy_mq-0.0.7.tar.gz
- Upload date:
- Size: 2.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.11.0 pkginfo/1.4.2 requests/2.18.4 setuptools/39.1.0 requests-toolbelt/0.8.0 tqdm/4.23.4 CPython/3.6.5
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8c1d6f5795d32514f1d2abc29982b75fe22f3b0559e11efe3aa62d120af058ae |
|
MD5 | 569f78bfe732a86acedf440691e2d6e2 |
|
BLAKE2b-256 | da3fd286c9db03c8edd6a469bdb4d102d6262f0e329cfe306aef48f46521ab91 |
File details
Details for the file easy_mq-0.0.7-py3-none-any.whl
.
File metadata
- Download URL: easy_mq-0.0.7-py3-none-any.whl
- Upload date:
- Size: 2.8 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/1.11.0 pkginfo/1.4.2 requests/2.18.4 setuptools/39.1.0 requests-toolbelt/0.8.0 tqdm/4.23.4 CPython/3.6.5
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 782d0f3394b7a48464326eea4abe9a2b737ef714972ab2e96fa4f72e82ad83e8 |
|
MD5 | 63c452f6741474ff0644454ffd43f09d |
|
BLAKE2b-256 | 4ef7c8a798a6e34b5d038ac10692a23886649e53d456c426364a58e688f617e9 |