summaryrefslogtreecommitdiff
path: root/amqp/channel.py
Commit message (Collapse)AuthorAgeFilesLines
* isort.Omer Katz2019-03-021-2/+2
|
* Fix crash in basic_publish when broker does not support connection.blocked ↵Matus Valo2019-01-171-2/+3
| | | | capability (#244)
* 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
| | | | | | * Improve return values in doc strings * Added queue and exchange integration tests
* Don't return method signature from AbstractChannel::wait() (#233)Matus Valo2018-12-311-2/+2
| | | | | | | | | | * Don't return method signature from AbstractChannel::wait() Commit f63f8fe9efbe3357741f32541ea2d7b063f7df09 added new parameter `method_sig` for wait() callback. This change breaks some parts of existing code. This commit handles this issue. * Fix basic_publish integration test
* Don't revive channel when connection is closing (#220)Matus Valo2018-12-301-4/+7
| | | | | | | | | | | | * Don't revive channel when connection is closing * When connection is closing dont raise error when Channel.Close method is received * Added unitests * Fix flake8 * Fix typo
* Fix basic_consume() with no consumer_tag provided (#221)Matus Valo2018-11-261-5/+17
| | | | | | | | | | | | | | | | * Use consumer tag sent by broker instead of using directly parameter value * Added more unittests of basic_consume() method * Make pep8 happy * Split integration tests to connection tests and channel tests * Added connection closed integration test * Added integration tests for basic_consume() * Fix typos
* Drain events before publish data. (#214)Matus Valo2018-11-071-0/+9
| | | | | | | | | | | | | | * Drain events before publish data. Data are drained to checked if server sent connection blocked/unblocked notification. * s/assert_called_with/assert_called_once_with/ * Add unittest of connection blocked when broker does not support it * Improve naming of tests * Added unittest for publishing when connection is closed
* Handle negative acknowledgments sent by RMQ (#208)Matus Valo2018-10-191-2/+20
| | | | | | | | | | | | | | | | | | * Handle negative acknowledgments sent by RMQ * Make flake8 happy * Update documentation * Fix redundant parameter in _on_basic_nack + added unittests * Increase coverage of unittests * Move MessageNacked to exceptions.py * Make flake8 happy * Make flake8 happy
* 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
| | | | | | | Fixes deprecation warning during tests: DeprecationWarning: The 'warn' method is deprecated, use 'warning' instead https://docs.python.org/3/library/logging.html#logging.Logger.warning
* 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 ↵Ask Solem2015-12-081-1/+10
| | | | celery/celery#2564)
* 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
| | | | Closes celery/celery#2312
* 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 ↵Ask Solem2014-01-131-2/+10
| | | | celery/kombu#296
* 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
| | | | Closes #3
* queue_declare and basic_return now gives namedtuplesAsk Solem2013-09-221-12/+13
|
* Merge branch '1.0'Ask Solem2013-03-081-3/+5
|\ | | | | | | | | | | | | | | Conflicts: Changelog README.rst amqp/__init__.py funtests/test_channel.py
| * 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
|\ \ | |/ | | | | | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: Changelog README.rst amqp/__init__.py amqp/abstract_channel.py amqp/channel.py amqp/connection.py amqp/exceptions.py amqp/method_framing.py amqp/serialization.py amqp/transport.py docs/includes/intro.txt funtests/test_serialization.py
| * 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