summaryrefslogtreecommitdiff
path: root/amqp/channel.py
Commit message (Expand)AuthorAgeFilesLines
* isort.Omer Katz2019-03-021-2/+2
* Fix crash in basic_publish when broker does not support connection.blocked ca...Matus Valo2019-01-171-2/+3
* basic_consume() should return consumer tag instead of tuple (#240)Matus Valo2019-01-151-1/+5
* queue, exchange and basic.get integration tests (#234)Matus Valo2019-01-041-4/+7
* Don't return method signature from AbstractChannel::wait() (#233)Matus Valo2018-12-311-2/+2
* Don't revive channel when connection is closing (#220)Matus Valo2018-12-301-4/+7
* Fix basic_consume() with no consumer_tag provided (#221)Matus Valo2018-11-261-5/+17
* Drain events before publish data. (#214)Matus Valo2018-11-071-0/+9
* Handle negative acknowledgments sent by RMQ (#208)Matus Valo2018-10-191-2/+20
* isort.Omer Katz2017-10-281-5/+3
* Remove LGPL headers from source files as project has since changed to BSD (#163)Adam Smith2017-08-241-14/+0
* Use Logger.warning() as Logger.warn() is deprecated (#142)Jon Dufresne2017-04-161-1/+1
* Adds pydocstyle tox targetAsk Solem2016-10-111-77/+48
* set literalAsk Solem2016-06-151-2/+2
* Fixes basic_publish after connection closeAsk Solem2016-05-111-1/+5
* flakesAsk Solem2016-04-081-1/+3
* Removes outdated funtests directoryAsk Solem2016-04-061-1/+1
* acknowledgment (US) not acknowledgEmentAsk Solem2016-03-221-3/+3
* Adds timeout argument to basic_publishAsk Solem2016-03-021-5/+11
* Now uses vine for promisesAsk Solem2016-03-021-1/+2
* Adds extra check for celery/celery#2527Ask Solem2015-12-101-1/+6
* Now reject+requeues messages for which there are no callbacks (Issue celery/c...Ask Solem2015-12-081-1/+10
* Unit tests for amqp, with 96% coverage so farAsk Solem2015-12-071-6/+4
* Fixes basic.getAsk Solem2015-10-301-4/+10
* Python 2.7ismAsk Solem2015-10-191-1/+1
* Single-item tuples now allowed without whitespaceAsk Solem2015-07-131-6/+6
* Implements Connection.collect() to close connection/channels fast.Ask Solem2014-10-241-2/+2
* first argument to channel.close must be short. Closes #47Ask Solem2014-08-111-1/+1
* Implements Connection.then and Channel.thenAsk Solem2014-06-051-1/+9
* Connection handshake now callback based, and lots of cosmeticsAsk Solem2014-06-051-461/+87
* Always use unpack_from (no string slices) and adds amqp.spec classes referenceAsk Solem2014-06-041-151/+106
* Refactors AMQPReaderAsk Solem2014-06-041-69/+75
* Refactoring AMQPWriter and _send_methodAsk Solem2014-06-041-279/+201
* Fixes flakes after flake8 upgradeAsk Solem2014-05-271-1/+0
* Make sure exchange auto_delete deprecation warning is visible. Closes celery...Ask Solem2014-01-131-2/+10
* Message.channel must be channel object, not id. Closes #24Ask Solem2013-10-291-2/+7
* FlakesAsk Solem2013-10-041-1/+1
* Adds confirm_publish argument to Connection (always wait for publisher confirm)Ask Solem2013-10-041-1/+16
* queue_declare and basic_return now gives namedtuplesAsk Solem2013-09-221-12/+13
* Merge branch '1.0'Ask Solem2013-03-081-3/+5
|\
| * channel(id) should claim id from array of free idsAsk Solem2013-03-081-1/+4
| * Fixes typo handlers -> events. Closes #9Ask Solem2013-03-081-1/+1
* | Merge branch '1.0'Ask Solem2013-02-121-10/+10
|\ \ | |/
| * flakesAsk Solem2013-02-081-15/+14
| * Don't attempt to close channel if no connection. Fixes celery/celery#1095Ask Solem2012-11-291-1/+1
| * Ignore basic_cancel if channel closed.Ask Solem2012-11-211-8/+9
| * Channel.events is now a dict of setsAsk Solem2012-11-211-1/+1
| * Use array.array to keep track of unused channel idsAsk Solem2012-11-121-3/+5
* | Fixes AttributeError in _send_methodAsk Solem2013-02-041-0/+2
* | Pep8ify + cosmeticsAsk Solem2013-01-171-17/+17
View Lorry Controller Status