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

docs: Update a few connect methods

3313172411df1a72479c2734a9980b6ed9ef4cd4 authored about 9 years ago by Benoit Calvez <[email protected]>
docs: update changelog for heartbeat method

bb9be2300486a21b004e5c6a6bd6b2351d31d04e authored about 9 years ago by Benoit Calvez <[email protected]>
protocol: Add a handler to the heartbeat, closes: #3

the heartbeat is sent by the server if NO traffic is sent from the server.
so the heartbeat is f...

94eceb00e4c1a3ed5e0332a370eefac4a6c97c49 authored about 9 years ago by Benoit Calvez <[email protected]>
protocol: the connexion tuning are parametrable

2a233f1945fe9488d3087137b93fdf0292b83abb authored about 9 years ago by Benoit Calvez <[email protected]>
channel: ensure we don't mess with waiter when the connection is closing

4e6576bac45d83f36688c9fda665ed479dad053b authored about 9 years ago by Benoit Calvez <[email protected]>
channel: Do not enforce checks of callback type, refs #55

This commits breaks the API of all others versions: the signature of basic_consume changed.

The...

8fcc4826af63bc377ace93ad7ab18d4e171fc68a authored about 9 years ago by Benoit Calvez <[email protected]>
wip: remove the coroutine check on the callback

de6007af59b28d967a473e2c0e92d2634cafff1e authored about 9 years ago by Benoit Calvez <[email protected]>
Add Python 3.5 to travis

81a15c2cee658008abca54475ba6f106954b0dda authored about 9 years ago by Matthias Urlichs <[email protected]>
Merge branch 'upstream' into debian

6f4ceba2ad228d868cf9bdbbe8b18011bab0daad authored about 9 years ago by Matthias Urlichs <[email protected]>
Actually close the stream writer when closing the protocol

This fixes a ResourceWarning with Py3.5

66bdd11653b8083ec18e1b22450ca46e247cb604 authored about 9 years ago by Matthias Urlichs <[email protected]>
setup.py: add Python 3.5 compatibility

ed142468aa31a2ac432f22b2837acca1628376a8 authored about 9 years ago by Matthias Urlichs <[email protected]>
Merge branch 'upstream' into debian

f6813a4f44d97f6c30568f959db5a9df7788bf79 authored about 9 years ago by Matthias Urlichs <[email protected]>
Use asyncio.ensure_future instead of .async

This avoids a depecation warning under Python 3.5.

f65efa3e2be39f3d05de8cb9645750a77e838fa2 authored about 9 years ago by Matthias Urlichs <[email protected]>
* Rebased.

75040c8cf6889d7248090a78819862896ee5ecc6 authored about 9 years ago by Matthias Urlichs <[email protected]>
* clean up the description

b635664d571c7d00689aa13df4e2feacd3f2506e authored about 9 years ago by Matthias Urlichs <[email protected]>
ignore .pybuild

d4639d41cf2f1cd6d3a14ad78795ecc22b01227a authored about 9 years ago by Matthias Urlichs <[email protected]>
Debianized.

ea1e544852413c6b383eacebaadf9a16e150e5bb authored about 9 years ago by Matthias Urlichs <[email protected]>
test_protocol: close the connection

Otherwise we get a nasty "Task was destroyed but it is pending!"
traceback under Python 3.5 (whi...

e4f41cff53e1dde59b304e1cfb85b69969048449 authored about 9 years ago by Matthias Urlichs <[email protected]>
add Matthias Urlichs to AUTHORS and update eventloop changelog

d89d90099c2d6f66b3f9a9a94cd913d288d6d19b authored about 9 years ago by Benoit Calvez <[email protected]>
a couple more docstrings

e89e33fd0f07a4f91075b8cc30b76d75760b067b authored about 9 years ago by Matthias Urlichs <[email protected]>
document loop option

85b668d8bdbc5051d0c39e24a4178cc06070fe98 authored about 9 years ago by Matthias Urlichs <[email protected]>
Add tests for using a separate event loop

except for test_protocol (asyncio complains because of multithreading;
the test would acually su...

7821edbb1ad119b518ae4f1001ff1c072d225e02 authored about 9 years ago by Matthias Urlichs <[email protected]>
fix typo

hearbeat?

b5c362e5aa7a080732727b53e0ea8a2b221a0199 authored about 9 years ago by Matthias Urlichs <[email protected]>
Allow using a non-default event loop

09725b2770b7848ca4e7b1d435b24788c6e45626 authored about 9 years ago by Matthias Urlichs <[email protected]>
Missing @testing.coroutine decorators cause tests to get executed partially.

e1862523f593686fc2f3ed435fb1d12597098fe3 authored about 9 years ago by Matthias Urlichs <[email protected]>
cleanup comments about using rabbitmqctl

096c2acffc1a50d4f43d1b779d543321a105ea52 authored about 9 years ago by Benoit Calvez <[email protected]>
AUTHORS: add Dmitry Maslov

25addf6c5d7a96ad10bd6f038738a2fc2af875fe authored about 9 years ago by Benoit Calvez <[email protected]>
from_url now passes kwargs to connect()

dc0299447ceac9d72b6c788d6dffcf5cf92c98ac authored about 9 years ago by Dmitry Maslov <[email protected]>
tests: remove rabbitctl_list method

ecb150ef031d11759b6f8c5fb0cb9052c316c3eb authored about 9 years ago by Benoit Calvez <[email protected]>
tests: cleanly close transports

f83058658fd77ae549ceaa7f00c76fd71ea9cb3d authored about 9 years ago by Benoit Calvez <[email protected]>
docs: and entry about channel recycling optim

d6ce86f641364ec73249f8c5ee2a17d0122fb824 authored about 9 years ago by Benoit Calvez <[email protected]>
Fix a channel test

149d6133583c60a21e831de2fb4e528f52d295ba authored about 9 years ago by Marco Paolini <[email protected]>
Channel: Make channel id recycling less memory hungry

0e094fe746a9a39f96b5fdc9d8c3874552d4c9d7 introduced reuse of channel
id.

The implementation all...

3f3a4e4fcc76e1bdb1f2ef66516bd4f14ff87e18 authored about 9 years ago by Marco Paolini <[email protected]>
tests: remove the use of rabbitmqctl.

Use the rabbitmq http API to manage rabbit vhost in a TestCase.

d5d6f9cbedbd30ce6463adc70828c5f277c20b61 authored about 9 years ago by Benoit Calvez <[email protected]>
docs: update theme and html output dirs.

Commit to match Polyconseil's sphinx docs

4b36072bb69af89776dad015196603d5ff5a9d5b authored about 9 years ago by Benoit Calvez <[email protected]>
protocol: allows to configure amqp connection informations

The amqp protocols provides some way of configuration to know
what program is connected to the b...

ba44af6a0dd817572ab53a31daa240ffa1ffb4a0 authored over 9 years ago by Benoit Calvez <[email protected]>
connect: avoid name collision when using kwargs and the lambda

645c6bb2f83d52c4c1af34f519752f2eeb916169 authored over 9 years ago by Benoit Calvez <[email protected]>
Change debug log text

Corrected misprint in "openned"

f6c774288502838fcf896248dbc26a04518bf07b authored over 9 years ago by Vadim Markovtsev <[email protected]>
release.conf: remove unneeded options.

These are the default values.

2cb6f1d066a3a6ed804dc421ff7239c4de861578 authored over 9 years ago by Damien Baty <[email protected]>
changelog: add entry about SSL support

6efe9e0ca39260bb1b9569119b0fd62cac8e4d38 authored over 9 years ago by Benoit Calvez <[email protected]>
Merge pull request #42 from mwfrojdman/ssl

Add SSL support

4bd9e2d3b1f22406264657e0c433a9f38a443217 authored over 9 years ago by Benoît C <[email protected]>
merge

836621965f8ff09c8cedbfd0e3c834112674adb1 authored over 9 years ago by Mathias Fröjdman <[email protected]>
Add ssl support

5051b5e0a6970d86ce5cb9a80a48e44b89c48b40 authored over 9 years ago by Mathias Fröjdman <[email protected]>
changelog: 0.4.0 is released

0c808d2fe6073e0d0bd458e156c958f23df59b4f authored over 9 years ago by Benoit Calvez <[email protected]>
Bump version number

961354c8109a10ad00824a1417f2fc90320d265c authored over 9 years ago by Benoit Calvez <[email protected]>
aioamqp: import exceptions in the module

fda82feac473d42d4c8e2e4500de4ef2a2a3e623 authored over 9 years ago by Benoit Calvez <[email protected]>
protocol: correctly call the error callback.

The protocol doesn't call the error callback in some circumstances

e8304b87b3268f464ba856ba1bcade716344480f authored over 9 years ago by Benoit Calvez <[email protected]>
from_url now returns the transport and the protocol.

dee08e7c291e9b038fbd5acd89888f87b51ded98 authored over 9 years ago by Benoit Calvez <[email protected]>
docs: guess aioamqp version dynamically

483f6f4269a9fc4bbe0bdaa66b3d6293dcf99224 authored over 9 years ago by Benoit Calvez <[email protected]>
Bump version number

Also adds a changelog

285218ba51b372efcc92966b4438d65cb36ebac4 authored over 9 years ago by Benoit Calvez <[email protected]>
channel: reuse previous closed channel id, closes: #36

0e094fe746a9a39f96b5fdc9d8c3874552d4c9d7 authored over 9 years ago by Benoit Calvez <[email protected]>
channel: connection_closed is not a coroutine

5af15e429c1e2e6ab040be651e832f68fa79a9af authored over 9 years ago by Benoit Calvez <[email protected]>
docs: Replace enveloppe with Envelope

f2fc7d86632ba1b7fbd9143d34e337be26ecb82e authored over 9 years ago by Benoit Calvez <[email protected]>
Update authors

88342cd10bf244d5acc6c0a176f404f4d1bad512 authored over 9 years ago by Benoit Calvez <[email protected]>
docs: update callback arguments

0c45ce78420824de5f4b5679d71de62e3af67141 authored over 9 years ago by Benoit Calvez <[email protected]>
Merge pull request #33 from mwfrojdman/fork

Parse and deliver whole message to callback for basic consume, support RabbitMQ publisher confirms

e9005d9342c2395476fe90a902ecef2b9a385229 authored over 9 years ago by Benoît C <[email protected]>
Envelope and Properties classes for passing values from basic deliver messages to consumer callbacks

ed01998264958a53f7524835debac78623580f45 authored over 9 years ago by Mathias Fröjdman <[email protected]>
Test properties in basic delivery messages using reply_to and

correlation_id

2691e2897068ebb44ed32eaee43dabc28c286500 authored over 9 years ago by Mathias Fröjdman <[email protected]>
allow overriding nosetests command

982802729095b4944b67e9c9366823e3030c30d6 authored over 9 years ago by Mathias Fröjdman <[email protected]>
Patches for supporting properties in delivery messages and RabbitMQ

publish confirm

3ef44fdb397c13c3ae71fff247e74f69b9dcda87 authored over 9 years ago by Mathias Fröjdman <[email protected]>
frame: write int as a long

01365e2cbfb12e94f236860b5fecde6f447749a2 authored over 9 years ago by Benoit Calvez <[email protected]>
Merge pull request #29 from roncohen/remove-policy-arg-in-list-queues

Remove 'policy' argument from list_queues in tests.

ca7c6da53246774019ebb988c92ffc292ddc73bb authored almost 10 years ago by Benoît C <[email protected]>
Makefile: add update: target

706fa7d757755256df6437c3fe3183f495d5aca2 authored almost 10 years ago by Benoit Calvez <[email protected]>
tests: vhost is configurable via AMQP_VHOST env

5a8c778d1febe312cf9e73aa3f1c42e311293125 authored almost 10 years ago by Benoit Calvez <[email protected]>
Remove 'policy' argument from list_queues in tests.

RabbitMQ version 2.7.1 doesn't seem to support the 'policy' argument with `rabbitmq list_queues`...

3db84f5d663ea1483c92d6c01e7fe389806b3399 authored almost 10 years ago by Ron Cohen <[email protected]>
travis: python 3.4 is python 3.4.1 now

7b715d0a401664a06b38684a4ef0159363df9fb0 authored about 10 years ago by Fabien Bochu <[email protected]>
docs: fix documentation build

d276a48180e341d719bedf516a3594ddf6af8fb6 authored about 10 years ago by Cedric bache <[email protected]>
Bump version number

fe18e8a4fe744771441ae52dcdb4ee2a1100da5d authored about 10 years ago by Benoit Calvez <[email protected]>
encode correlation_id as string, close #21

c2e715ed88dae48cdfcc8791d3b604e026b22bc6 authored about 10 years ago by Cedric bache <[email protected]>
add Makefile

cea3b41bd798927647fe6279717a92225bdaae37 authored about 10 years ago by Cedric bache <[email protected]>
connect() also return transport

fb5930cbdfafab09323181980ca8362dcaa61d68 authored about 10 years ago by Cedric bache <[email protected]>
fix test for rabbitmq3.4.1

046de3107872b13ea3b089728803ca66aabdbd74 authored about 10 years ago by Cedric bache <[email protected]>
update asyncio required version

ec6652468eed7c728f8c0425b1640cb40f3ec80d authored about 10 years ago by Benoît C <[email protected]>
setup: use environment marker in setup.py

add setup.cfg for wheel generation

2089ee00cc03c97f78a5c9dbee6061e7b99f84b9 authored about 10 years ago by Xavier Fernandez <[email protected]>
Update CHANGES.rst

1f55d80faa8c6fcc42067b859b01b4e3279ac831 authored over 10 years ago by Benoit Calvez <[email protected]>
Bump version number

800878fbcbb763c833538a20fcbd4fe5c483297c authored over 10 years ago by Benoit Calvez <[email protected]>
examples: Use the callback when consuming

45bb90b4ba3782ecff557a74b412e173556e22d8 authored over 10 years ago by Benoit Calvez <[email protected]>
Remove py2 examples

05fbe90d3d296be242219b9743ee053ccc4e0ae5 authored over 10 years ago by Benoit Calvez <[email protected]>
docs: Update basic_consume part.

254c8109ebfe5a64db57e91b1f1fcf5e4ceb8445 authored over 10 years ago by Benoit Calvez <[email protected]>
Code cleanup (duplicate methods)

85472cb3ff656b091327ea31fc32754c61955e92 authored over 10 years ago by Benoit Calvez <[email protected]>
Add "on_error" callback on protocol and channel

fa5d47ac7695ffbf21b80ac724b24b19d951061b authored over 10 years ago by Benoit Calvez <[email protected]>
Fix if: from ex

4f3f130278f958fe356c4f9d9429cef15d40fc27 authored over 10 years ago by Benoit Calvez <[email protected]>
channel: cleanup consumelock event

7b5e2cfb9b0ac1446eb6e918fa4a0f3da58500ad authored over 10 years ago by Benoit Calvez <[email protected]>
consume: add sync' callaback test

28e6388be1bbd3e518d2c7a4f8986b46cceae20f authored over 10 years ago by Benoit Calvez <[email protected]>
channel: Add an event to sync consume_ok and callback

47cbc62b640ac981f1a5de28d0e3bd6b5646f0f1 authored over 10 years ago by Benoit Calvez <[email protected]>
Avoid catching KeyError on method dispatch

This mechanism prevent from catching method excpetion and not dispatch
ones

d120ae9660009b8d4834808455cd566084667370 authored over 10 years ago by Benoit Calvez <[email protected]>
package: Add python 3.4 to the classifiers

102b8084485fa32ca20af53bf73159515a1a9d47 authored over 10 years ago by Benoit Calvez <[email protected]>
few pylints

5347f12651e60e9118e834ccd7feb6d3af06383c authored over 10 years ago by Benoit Calvez <[email protected]>
frame: move server_close to channel

5936697ede53c93342843ed59f2c28810f3848e5 authored over 10 years ago by Benoit Calvez <[email protected]>
Move frame basic parsing to channel class

f17a7f00faedfcc4cb4ae33718701cbffaca455f authored over 10 years ago by Benoit Calvez <[email protected]>
channel: move frame argument decoding to queue_decalare_ok

878a1bf1ba904af3c18c5f0dec1a29beeedd396a authored over 10 years ago by Benoit Calvez <[email protected]>
frame: Remove old debug method frame()

16e4f962108159d4a4fbe40de6a6901a8731ffd3 authored over 10 years ago by Benoit Calvez <[email protected]>
Add tests following the refact

4daf6c1cee4a8f78198f8761476c7bfff3690722 authored over 10 years ago by Benoit Calvez <[email protected]>
channel: check for a coroutine function

ff74ee7359910dd4647be58f11499e159549ce7a authored over 10 years ago by Benoit Calvez <[email protected]>
Fix test_close

4fc6f92fe1e129024342a3d7b634806ff7d9ae17 authored over 10 years ago by Benoit Calvez <[email protected]>
travis: remove asyncio patch

66bc2f2a39041deb300f6d6f0301eeeabd27ba08 authored over 10 years ago by Benoit Calvez <[email protected]>
tests: Disable "inactive flow" on travis

544cdbae7333818b10e45870f7df48ac8f8d8f64 authored over 10 years ago by Benoit Calvez <[email protected]>
Add missing constants

c84ac8ad6c8e07bd1e9ba483fb8d36627e87cfcf authored over 10 years ago by Benoit Calvez <[email protected]>
Protocol closes the channel when receiving an error

b7585158e21a3cb43b1f3f1a61ecfa285c926ee7 authored over 10 years ago by Benoit Calvez <[email protected]>
Add python 3.4.1 to travis

d04b60a567dc4e536103533765826ebe487a0d02 authored over 10 years ago by Benoit Calvez <[email protected]>