Ecosyste.ms: OpenCollective
An open API service for software projects hosted on Open Collective.
github.com/python-trio/trio-amqp
Asynchronous messaging for snake people
https://github.com/python-trio/trio-amqp
channel: Wait on queue_declare and others
When parameter no_wait is False (means we want to have a response from
the server), the function...
protocol: Fix rabbit errors handling
233cd11cf1a217df0fe402d01587549bd2e0e11e authored over 10 years ago by Thomas Recouvreux <[email protected]>
233cd11cf1a217df0fe402d01587549bd2e0e11e authored over 10 years ago by Thomas Recouvreux <[email protected]>
exchange_declare: Fix payload
20fa0d332a257d82db6439df62d44929bd1c138d authored over 10 years ago by Thomas Recouvreux <[email protected]>
20fa0d332a257d82db6439df62d44929bd1c138d authored over 10 years ago by Thomas Recouvreux <[email protected]>
Add pika (py2) examples
3e002f818e2b634da46c7663f3486ca4909f0b00 authored over 10 years ago by Thomas Recouvreux <[email protected]>
3e002f818e2b634da46c7663f3486ca4909f0b00 authored over 10 years ago by Thomas Recouvreux <[email protected]>
Add pub/sub sample 5 consummer
7df04d5e015ebef2abb81e12ef1ff59ef203cd38 authored over 10 years ago by Thomas Recouvreux <[email protected]>
7df04d5e015ebef2abb81e12ef1ff59ef203cd38 authored over 10 years ago by Thomas Recouvreux <[email protected]>
Add pub/sub sample 3 consummer
53321bf427fb275d26d5ef9bd2aa0b4b09b95d0e authored over 10 years ago by Thomas Recouvreux <[email protected]>
53321bf427fb275d26d5ef9bd2aa0b4b09b95d0e authored over 10 years ago by Thomas Recouvreux <[email protected]>
Add pub/sub sample 4 consummer
378752fd8faa82b93bbba526589d0f4760495a67 authored over 10 years ago by Thomas Recouvreux <[email protected]>
378752fd8faa82b93bbba526589d0f4760495a67 authored over 10 years ago by Thomas Recouvreux <[email protected]>
Add basic encoder tests
50546e0c5d90d81ee4dfc2646eaf494e5a3ce2e5 authored over 10 years ago by Thomas Chaumeny <[email protected]>
50546e0c5d90d81ee4dfc2646eaf494e5a3ce2e5 authored over 10 years ago by Thomas Chaumeny <[email protected]>
Remove unused 'close' method (it's not part of the Protocol API)
1260e2ee19374bd193ce55d01b351f806883140f authored almost 11 years ago by Thomas Chaumeny <[email protected]>
1260e2ee19374bd193ce55d01b351f806883140f authored almost 11 years ago by Thomas Chaumeny <[email protected]>
Add a few docs
9e5d720b0c76bdd6ff02e7f0e49df73c06559cc1 authored almost 11 years ago by Benoit Calvez <[email protected]>
9e5d720b0c76bdd6ff02e7f0e49df73c06559cc1 authored almost 11 years ago by Benoit Calvez <[email protected]>
protocol: configurable login and password
c0743c2fe9b482ad28a2528227656f6e73b3df8c authored almost 11 years ago by Benoit Calvez <[email protected]>
c0743c2fe9b482ad28a2528227656f6e73b3df8c authored almost 11 years ago by Benoit Calvez <[email protected]>
channel: Missing self.message_queue declaration
328be4406166a9ecccca8e2088b3f03e4f214e40 authored almost 11 years ago by Benoit Calvez <[email protected]>
328be4406166a9ecccca8e2088b3f03e4f214e40 authored almost 11 years ago by Benoit Calvez <[email protected]>
channel: Correctly consume a message
Breaks the API: channel.consume() will now return:
* consumer_tag
* delivery_tag
* blob
Implement hearbeat frames
b13a04f58c55d0c74a6bb2930bc206f12610481a authored almost 11 years ago by Benoit Calvez <[email protected]>
b13a04f58c55d0c74a6bb2930bc206f12610481a authored almost 11 years ago by Benoit Calvez <[email protected]>
Update python packaging
2fd36f85709362fb934f353b1533650a999a615f authored almost 11 years ago by Benoit Calvez <[email protected]>
2fd36f85709362fb934f353b1533650a999a615f authored almost 11 years ago by Benoit Calvez <[email protected]>
Fix a few frames rubbish
related to https://github.com/Polyconseil/aioamqp/issues/1
db1fb7a6262da91564774a792c2d215f9a4848f0 authored almost 11 years ago by Benoit Calvez <[email protected]>
Implements some rudiments to consume messages
c8d3b13e7145df1e3943175945ef12a1680f91db authored almost 11 years ago by Benoit Calvez <[email protected]>
c8d3b13e7145df1e3943175945ef12a1680f91db authored almost 11 years ago by Benoit Calvez <[email protected]>
Implement some of the `basic' amqp's method
6bf8231cd81c2a9bd66dc396c8cb06a2600a081d authored almost 11 years ago by Benoit Calvez <[email protected]>
6bf8231cd81c2a9bd66dc396c8cb06a2600a081d authored almost 11 years ago by Benoit Calvez <[email protected]>
Add a first setup.py
e2dc7cf697d533779ff8d3d5015f40693571a7d2 authored almost 11 years ago by Benoit Calvez <[email protected]>
e2dc7cf697d533779ff8d3d5015f40693571a7d2 authored almost 11 years ago by Benoit Calvez <[email protected]>
Update channel's API
cb7bfa4f8e203cd5fdbf83ede16b7496c14d18bd authored almost 11 years ago by Benoit Calvez <[email protected]>
cb7bfa4f8e203cd5fdbf83ede16b7496c14d18bd authored almost 11 years ago by Benoit Calvez <[email protected]>
Add rabbitmq consumers examples that uses aioamqp
ba71581bdb51085b261ac276656e02c413294227 authored almost 11 years ago by Benoit Calvez <[email protected]>
ba71581bdb51085b261ac276656e02c413294227 authored almost 11 years ago by Benoit Calvez <[email protected]>
First messages properties implementation
8436e780cd3e7d2540251197ea19679a7413b717 authored almost 11 years ago by Benoit Calvez <[email protected]>
8436e780cd3e7d2540251197ea19679a7413b717 authored almost 11 years ago by Benoit Calvez <[email protected]>
Handle Content-Header and Content-Body frames
At this point, we effectiveley send messages to rabbitmq
35b44ed36683127f6507c2748bf5ea1b317ad06d authored almost 11 years ago by Benoit Calvez <[email protected]>
Sends basic messages to an exchange
70f40c95c76efbebb441c0055f1b0ba609c5b160 authored almost 11 years ago by Benoit Calvez <[email protected]>
70f40c95c76efbebb441c0055f1b0ba609c5b160 authored almost 11 years ago by Benoit Calvez <[email protected]>
bind queue
61c04fb39a9968582026e59edafbe253aeda2c1a authored almost 11 years ago by Benoit Calvez <[email protected]>
61c04fb39a9968582026e59edafbe253aeda2c1a authored almost 11 years ago by Benoit Calvez <[email protected]>
declare a channel, a queue. Cleanly close a connection.
6489ae971612335a5288910b9a7d468eb5e850e5 authored almost 11 years ago by Benoit Calvez <[email protected]>
6489ae971612335a5288910b9a7d468eb5e850e5 authored almost 11 years ago by Benoit Calvez <[email protected]>
Add rudiments to connect to rabbitmq
* start
* start-ok
* tune
* tune-ok
* open
* open-ok
Initial commit
a84260dab04b1ba741caac75989522caf59d6e2f authored almost 11 years ago by Benoît C <[email protected]>
a84260dab04b1ba741caac75989522caf59d6e2f authored almost 11 years ago by Benoît C <[email protected]>