simple rpc amqp python library on pike
Project description
usage
simple rpc amqp python library on pike
consumer
s = ServiceCreator('amqps://user:password@host.cloudamqp.com/vhost',
"exchangepypy")
def cb(msg):
print(msg)
return msg
s.consume("py.test", "", cb)
rpc request
s = ServiceCreator('amqps://user:password@host.cloudamqp.com/vhost',
"exchangepypy")
res,err = s.rpc_request("py.test", "sdsdsdsd", 0)
print(res,err)
fire and forget
s = ServiceCreator('amqps://user:password@host.cloudamqp.com/vhost',
"exchangepypy")
s.fire_and_forget("py.test", "cvvccvvcv")
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
amqp_py_client-0.0.2.tar.gz
(1.3 kB
view hashes)
Built Distribution
Close
Hashes for amqp_py_client-0.0.2-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | e0ec5bda2c988b215835c7b0a7e5e8b6a4b64463046b80c6ebbdec56b73afffe |
|
| MD5 | fcea3ae7365fdcd9a68d381653876352 |
|
| BLAKE2b-256 | feec61308f4905d0ea2935510f5aea0771c94408aa2fcc9bb1520ce091784019 |
