summaryrefslogtreecommitdiff
path: root/kombu/messaging.py
Commit message (Expand)AuthorAgeFilesLines
* Bump pyupgrade version and add __future__.annotations importMarcelo Trylesinski2022-04-151-7/+9
* chore: Update `__exit__` signaturesSondre Lillebø Gundersen2022-04-121-2/+16
* enable pre-commit (#1355)Thomas Grainger2021-07-201-2/+2
* Add timeout to producer publish (#1269)RezaSi2020-11-171-4/+10
* Remove five usage from kombu/.Omer Katz2020-07-231-9/+6
* pyupgradeOmer Katz2020-07-131-5/+4
* Used a tuple instead of a list to define __all__. (#945)Mads Jensen2018-11-121-1/+1
* disambiguate docstring typehints causing warnings building celery docs (#941)Noah Hall2018-11-011-2/+2
* Fix Closed connection and with statement blows up (#721)eavictor2017-04-181-1/+1
* Don't modify dict size while iterating over it (#676)Felix Yan2017-02-211-1/+2
* flakesAsk Solem2016-12-071-1/+2
* Producer: Fixes ever growing list of entities to declare. Closes #651Ask Solem2016-12-071-3/+5
* Consumer: __exit__ should not cancel if connection error (Closes #670)Ask Solem2016-12-071-5/+8
* Producer.auto_declare now declares on first publishAsk Solem2016-10-261-7/+6
* Adds pydocstyle as a tox targetAsk Solem2016-10-111-4/+3
* Reorganizes kombu.utils.__init__ packageAsk Solem2016-07-161-8/+2
* Use Google-style docstringsAsk Solem2016-07-161-99/+94
* flakesAsk Solem2016-06-151-1/+1
* Make sure __repr__ and __str__ returns bytes on Python 2Ask Solem2016-04-111-1/+3
* Use unicode_litereals everywhere and updates flakeplus target to --2.7Ask Solem2016-04-061-1/+1
* Removes deprecated Consumer.add_queue_from_dictAsk Solem2015-12-181-10/+0
* Consumer: Now keeps track of queues with a map instead of list giving O(n) ca...Ask Solem2015-12-181-12/+27
* Support for librabbitmqAsk Solem2015-10-221-2/+2
* Producer.publish reply_to argument can now be QueueAsk Solem2015-10-211-0/+5
* Adds Consumer tag_prefix option. Closes #509Ask Solem2015-10-051-2/+4
* Adds Consumer(prefetch_count=) argumentAsk Solem2015-09-181-1/+12
* Exchange.delivery_mode now defaults to None, and the default set later by Pro...Ask Solem2015-05-071-17/+26
* Accept TTL as seconds and as a floatAnastasis Andronidis2015-02-121-2/+2
* Add expiration time for each publishing messageAnastasis Andronidis2015-01-171-1/+5
* Optimizes maybe_declare for transient queuesAsk Solem2014-06-051-1/+1
* Qos apply_global flag is supported by RabbitMQAsk Solem2014-04-141-1/+0
* Fixes typoAsk Solem2014-02-131-1/+1
* Use numbers moduleAsk Solem2014-02-131-3/+5
* _receive_callback must also raise message.errorsAsk Solem2014-01-281-0/+2
* repr(producer) must not evaluate channelAsk Solem2013-12-171-1/+1
* Adds loop.call_soon and loop.run_foreverAsk Solem2013-10-071-0/+1
* Removes .common.entry_to_queue and .messaging.entry_to_queueAsk Solem2013-10-071-4/+0
* WordingAsk Solem2013-10-011-1/+1
* Renamed serialization.encode/decode -> .dumps, .loadsAsk Solem2013-09-241-2/+2
* ContentDisallowed testsAsk Solem2013-09-111-0/+3
* Merge branch '2.5'Ask Solem2013-09-101-1/+1
|\
| * Queue.get now supports accept argumentAsk Solem2013-09-091-10/+4
* | Fixes typo prepare_accept_encoding -> prepare_accept_contentAsk Solem2013-09-091-2/+2
* | Tests passingAsk Solem2013-09-091-10/+4
* | Merge branch '2.5'Ask Solem2013-04-171-3/+32
|\ \ | |/
| * Documentation improvements. Closes #130Ask Solem2013-04-171-3/+32
* | Merge branch '2.5'Ask Solem2013-04-151-2/+22
|\ \ | |/
| * Consumer.accept: A whitelist of content types/serializers to allowAsk Solem2013-04-111-2/+8
| * Adds Consumer.accept: A whitelist of content_types/serializer names to acceptAsk Solem2013-04-111-1/+15
* | Use except as excAsk Solem2013-02-121-1/+1
View Lorry Controller Status