Usage example
from asyncio import get_event_loop, coroutine
from colibri import Connection, BasicMessage
@coroutine
def go():
c = Connection()
msg = BasicMessage('test message')
with (yield from c):
channel = c.channel()
with (yield from channel):
yield from channel.exchange_declare('otherex', type='direct')
yield from channel.queue_declare('otherqueue')
yield from channel.queue_bind('otherqueue', 'otherex', 'route')
yield from channel.basic_publish(msg, 'otherex', 'route')
res = yield from channel.basic_get('otherqueue')
print("this is the result: ", res.body)
get_event_loop().run_until_complete(go())
Installation
Using pip:
$ pip install colibri
From the source (requires virtualenv or root):
$ setup.py install
1 maintainer
Metadata
1 maintainer
Release files for colibri 0.0.1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| colibri-0.0.1.tar.gz | 19.8 kB | Details |
Release files / colibri-0.0.1.tar.gz
| Download URL | colibri-0.0.1.tar.gz |
|---|---|
| Size | 19.8 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
910f6210d444b2a6a763cc69cbbc4f4199c26e49e690b6204eeffad7871376ae
|
|
BLAKE2b-256 checksum How to use checksums |
74cbdf1b3e939c3f9b2f33dcf1f848ab430c145632e7180de9befe1b351d66c4
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
