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...

84d129ed886e40a7975fc832717bc17fd0b18b10 authored over 10 years ago by Thomas Recouvreux <[email protected]>
protocol: Fix rabbit errors handling

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]>
Add pika (py2) examples

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]>
Add pub/sub sample 3 consummer

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]>
Add basic encoder tests

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]>
Add a few docs

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]>
channel: Missing self.message_queue declaration

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

779e737dc6c25a5919c2e12da0011aaa4aa0ea7b authored almost 11 years ago by Benoit Calvez <[email protected]>
Implement hearbeat frames

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]>
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]>
Implement some of the `basic' amqp's method

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]>
Update channel's API

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]>
First messages properties implementation

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]>
bind queue

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]>
Add rudiments to connect to rabbitmq

* start
* start-ok
* tune
* tune-ok
* open
* open-ok

cc8cf0b0d5997edaa86026c8148717cd2d81d549 authored almost 11 years ago by Benoit Calvez <[email protected]>
Initial commit

a84260dab04b1ba741caac75989522caf59d6e2f authored almost 11 years ago by Benoît C <[email protected]>