7d160884a9- Expanded test coverage - Don't require python-msgpack-python for testing until issues are fixed. It's an optional feature anyway
Sascha Peilicke
2013-04-30 09:59:35 +0000
eea138c9acAccepting request 171304 from devel:languages:python
Stephan Kulow
2013-04-17 21:17:05 +0000
461ef3cb7aAccepting request 163866 from devel:languages:python3
Todd R
2013-04-13 10:32:23 +0000
20af303231- Update to 2.5.10: Kombu 3 consumers will no longer accept pickle/yaml or msgpack by default, and you will have to explicitly enable untrusted deserializers either globally using kombu.enable_insecure_serializers, or using the accept argument to kombu.Consumer. - New utility function to disable/enable untrusted serializers. - kombu.disable_insecure_serializers - kombu.enable_insecure_serializers - Consumer: accept can now be used to specify a whitelist of content types to accept. If the accept whitelist is set and a message is received with a content type that is not in the whitelist then a :exc:~kombu.exceptions.ContentDisallowed exception is raised. Note that this error can be handled by the already existing on_decode_error callback Examples: Consumer(accept=['application/json']) Consumer(accept=['pickle', 'json']) - Now depends on amqp 1.0.11 - pidbox: Mailbox now supports the accept argument. - Redis: More friendly error for when keys are missing. - Connection URLs: The parser did not work well when there were multiple '+' tokens.
Alexandre Rogoski
2013-04-12 17:59:12 +0000
861a0aa8b1- Update to 2.5.9: - Pidbox: Now warns if there are multiple nodes consuming from the same pidbox. - Adds Queue.on_declared <kombu.Queue.on_declared> A callback to be called when the queue is declared, with signature (name, messages, consumers). - Now uses fuzzy matching to suggest alternatives to typos in transport names. - SQS: Adds new transport option queue_prefix. Contributed by j0hnsmith. - pyamqp: No longer overrides verify_connection. - SQS: Now specifies the driver_type and driver_name attributes. Fix contributed by Mher Movsisyan. - Fixed bug with kombu.utils.retry_over_time when no errback specified.
Alexandre Rogoski
2013-04-11 17:01:36 +0000
326fbfa425Accepting request 161684 from devel:languages:python
Stephan Kulow
2013-04-02 10:52:54 +0000
6acca9d41f- Update to 2.5.8: - Now depends on amqp 1.0.10 which fixes a Python 3 compatibility error. - Redis: Fixed a possible race condition (Issue #171). - Redis: Ack emulation/visibility_timeout can now be disabled using a transport option. Ack emulation adds quite a lot of overhead to ensure data is safe even in the event of an unclean shutdown. If data loss do not worry you there is now an ack_emulation transport option you can use to disable it: Connection('redis://', transport_options={'ack_emulation': False}) - SQS: Fixed boto v2.7 compatibility (Issue #207). - Exchange: Should not try to re-declare default exchange ("") (Issue #209). - SQS: Long polling is now disabled by default as it was not implemented correctly, resulting in long delays between receiving messages (Issue #202). - Fixed Python 2.6 incompatibility depending on exc.errno being available. Fix contributed by Ephemera.
Alexandre Rogoski
2013-03-21 21:58:27 +0000
b79923d815Accepting request 159590 from devel:languages:python
Stephan Kulow
2013-03-18 06:10:52 +0000
2d7b88b505- Update to 2.5.7: - Now depends on amqp 1.0.9 - Redis: A regression in 2.5.6 caused the redis transport to ignore options set in transport_options. - Redis: New socket_timeout transport option. - Redis: InconsistencyError is now regarded as a recoverable error. - Resource pools: Will no longer attempt to release resource that was never acquired. - MongoDB: Now supports the ssl option. Contributed by Sebastian Pawlus.
Alexandre Rogoski
2013-03-08 13:31:05 +0000
26f0725447Accepting request 155267 from devel:languages:python
Stephan Kulow
2013-02-13 11:10:21 +0000
364656dd22Accepting request 155216 from Cloud:OpenStack:Master
Alexandre Rogoski
2013-02-12 21:32:22 +0000
51549c3d51- Update to 2.5.6: - Now depends on amqp 1.0.8 which works around a bug found on some Python 2.5 installations where 2**32 overflows to 0.
Alexandre Rogoski
2013-02-08 20:17:02 +0000
3afec9997e- Update to 2.5.5: SQS: Now supports long polling (Issue #176). The polling interval default has been changed to 0 and a new transport option (wait_time_seconds) has been added. This parameter specifies how long to wait for a message from SQS, and defaults to 20 seconds, which is the maximum value currently allowed by Amazon SQS. Contributed by James Saryerwinnie. - SQS: Now removes unpickleable fields before restoring messages. - Consumer.__exit__ now ignores exceptions occurring while cancelling the consumer. - Virtual: Routing keys can now consist of characters also used in regular expressions (e.g. parens) (Issue #194). - Virtual: Fixed compression header when restoring messages. Fix contributed by Alex Koshelev. - Virtual: ack/reject/requeue now works while using basic_get. - Virtual: Message.reject is now supported by virtual transports (requeue depends on individual transport support). - Fixed typo in hack used for static analyzers. Fix contributed by Basil Mironenko.
Alexandre Rogoski
2013-02-07 19:38:37 +0000
0889001956Accepting request 148781 from devel:languages:python
Stephan Kulow
2013-01-17 14:19:37 +0000
d9d38031b9Accepting request 148681 from home:babelworx:ldig:branches:devel:languages:python
Ismail Dönmez
2013-01-16 12:21:05 +0000
5342c50475Accepting request 148608 from Cloud:OpenStack:Master
Alexandre Rogoski
2013-01-15 16:22:23 +0000
08405b4e75- Remove the upper bound on the python-amqp requirement. We have a never one and this shouldn't be a real issue
Sascha Peilicke
2013-01-15 13:07:35 +0000
09c086371d- Drop build requires on python3-2to3, it's in python3-devel now - Don't require "python(abi)", RPM does that automatically - Fix rpmlint shebang warning for test_serialization.py
Sascha Peilicke
2013-01-14 09:50:17 +0000
4877ed8757Accepting request 148108 from home:posophe:branches:devel:languages:python
Alexandre Rogoski
2013-01-11 18:13:07 +0000
30ec3aa22dAccepting request 145691 from devel:languages:python
Stephan Kulow
2012-12-19 12:15:03 +0000
e24c6aed03- Update to 2.5.4: - Fixed problem with connection clone and multiple URLs (Issue #182). Fix contributed by Dane Guempel. - zeromq: Now compatible with libzmq 3.2.x. Fix contributed by Andrey Antukh. - Fixed Python 3 installation problem (Issue #187).
Alexandre Rogoski
2012-12-10 17:36:49 +0000
7d8fe477f3Accepting request 144413 from devel:languages:python
Stephan Kulow
2012-12-10 13:26:35 +0000
6b8ed1f09fFixup last commit
Sascha Peilicke
2012-12-06 13:33:46 +0000
633d52244b- Add requirements on Python-2.6 compat modules Python-2.6 for SLES: + python-importlib and python-ordereddict
Sascha Peilicke
2012-12-06 12:52:36 +0000
0b033a1673- Update to 2.5.3: - Pidbox: Fixed compatibility with Python 2.6 - Aditional changes from 2.5.2: - [Redis] Fixed connection leak and added a new 'max_connections' transport option. - Aditional changes from 2.5.1 - Fixed bug where return value of Queue.as_dict could not be serialized with JSON (Issue #177). - Aditional changes from 2.5.0 - py-amqp is now the new default transport, replacing amqplib. The new py-amqp library is a fork of amqplib started with the following goals: - Uses AMQP 0.9.1 instead of 0.8 - Support for heartbeats (Issue #79 + Issue #131) - Automatically revives channels on channel errors. - Support for all RabbitMQ extensions - Consumer Cancel Notifications (Issue #131) - Publisher Confirms (Issue #131). - Exchange-to-exchange bindings: exchange_bind / exchange_unbind. - API compatible with librabbitmq so that it can be used as a pure-python replacement in environments where rabbitmq-c cannot be compiled. librabbitmq will be updated to support all the same features as py-amqp. - Support for using multiple connection URL's for failover. The first argument to kombu.Connection can now be a list of connection URLs: Connection(['amqp://foo', 'amqp://bar']) or it can be a single string argument with several URLs separated by semicolon:
Alexandre Rogoski
2012-12-05 05:07:13 +0000
cd0ee611efAccepting request 143780 from devel:languages:python
Stephan Kulow
2012-12-03 10:26:54 +0000
548315a1cbAccepting request 143779 from home:TheBlackCat:branches:devel:languages:python
Todd R
2012-12-01 22:00:34 +0000
c6664d79dcAccepting request 143536 from home:iartarisi:branches:devel:languages:python
Sascha Peilicke
2012-11-29 11:21:03 +0000
1b7ac7ec33- Update to 2.4.10: - Redis: Fixed race condition that could occur while trying to restore messages (Issue #171). Fix contributed by Ollie Walsh. - Redis: Each channel is now using a specific connection pool instance, which is disconnected on connection failure. - ProducerPool: Fixed possible dead-lock in the acquire method. - ProducerPool: force_close_all no longer tries to call the non-existent Producer._close. - librabbitmq: Now implements transport.verify_connection so that connection pools will not give back connections that are no longer working. - New and better repr() for Queue and Exchange objects. - Python3: Fixed problem with running the unit test suite. - Python3: Fixed problem with JSON codec.
Alexandre Rogoski
2012-11-25 11:32:40 +0000
0a740195feAccepting request 140792 from devel:languages:python
Stephan Kulow
2012-11-12 10:37:00 +0000
9904760537- Update to 2.4.8: - Redis: Fair queue cyle implementation improved (Issue #166). Contributed by Kevin McCarthy. - Redis: Number of messages to restore in one iteration is now unlimited, but can be configured using the unacked_restore_limit transport option. - Redis: A Redis based mutex is now used while restoring messages. - LamportClock.adjust now returns the new clock value. - Heartbeats can now be specified in URLs. Fix contributed by Mher Movsisyan. - Kombu can now be used with PyDev, PyCharm and other static analysis tools. - Fixes problem with msgpack on Python 3 (Issue #162). Fix contributed by Jasper Bryant-Greene
Alexandre Rogoski
2012-11-03 03:00:31 +0000
5cfecc2c31Accepting request 137361 from devel:languages:python
Stephan Kulow
2012-10-07 17:59:35 +0000
7403713438- Update to 2.4.7: - Virtual: Unknown exchanges now default to 'direct' when sending a message. - MongoDB: Fixed memory leak when merging keys stored in the db (Issue #159) Fix contributed by Michael Korbakov. - MongoDB: Better index for MongoDB transport (Issue #158). This improvement will create a new compund index for queue and _id in order to be able to use both indexed fields for getting a new message (using queue field) and sorting by _id. It'll be necessary to manually delete the old index from the collection.
Alexandre Rogoski
2012-09-19 01:56:53 +0000
7b058ccac2Accepting request 134271 from devel:languages:python
Ismail Dönmez
2012-09-16 23:29:26 +0000
b9af9d1e2e- Update to 2.4.5: - Last version broke installtion on PyPy and Jython due to test requirements clean-up.
Alexandre Rogoski
2012-08-30 17:05:23 +0000
7a3b4f3ebd- Update to 2.4.4: - amqplib: Fixed a bug with asynchronously reading large messages. - pyamqp: Now requires amqp 0.9.3 - Cleaned up test requirements.
Alexandre Rogoski
2012-08-29 18:09:16 +0000
251e840d67- Update to 2.4.3: - Fixed problem with amqp transport alias (Issue #154).
Alexandre Rogoski
2012-08-27 14:28:08 +0000
f34966a9c7- Removed tests as qe do not have python-amqp (only python-amqplib). - Update to 2.4.2: - Having an empty transport name broke in 2.4.1. - Aditional changes from 2.4.1: - Redis: Fixed race condition that could cause the consumer to crash (Issue #151) Often leading to the error message "could not convert string to float" - Connection retry could cause an inifite loop (Issue #145). - The amqp alias is now resolved at runtime, so that eventlet detection works even if patching was done later.
Alexandre Rogoski
2012-08-24 19:56:58 +0000
e5dd14f468- Update to 2.4.0: - New experimental ZeroMQ transport. Contributed by John Watson. - Redis: Ack timed-out messages were not restored when using the eventloop. - Now uses pickle protocol 2 by default to be cross-compatible with Python 3. The protocol can also now be changed using the PICKLE_PROTOCOL environment variable. - Adds Transport.supports_ev attribute. - Pika: Queue purge was not working properly. Fix contributed by Steeve Morin. - Pika backend was no longer working since Kombu 2.3 Fix contributed by Steeve Morin.
Alexandre Rogoski
2012-08-17 20:36:07 +0000
980de3e33f- Update to 2.3.2: - Fixes problem with deserialization in Python 3. - Aditional changes from 2.3.1: - librabbitmq: Can now handle messages that does not have a content_encoding/content_type set (Issue #149). Fix contributed by C Anthony Risinger. - Beanstalk: Now uses localhost by default if the URL does not contain a host.
Alexandre Rogoski
2012-08-01 19:05:36 +0000
865d1c7c99- Update to 2.3.0: - New pyamqp:// transport! The new py-amqp library is a fork of amqplib started with the following goals: - Uses AMQP 0.9.1 instead of 0.8 - Should support all RabbitMQ extensions - API compatible with librabbitmq so that it can be used as a pure-python replacement in environments where rabbitmq-c cannot be compiled. py-amqp: http://amqp.readthedocs.org/ If you start using use py-amqp instead of amqplib you can enjoy many advantages including: - Heartbeat support (Issue #79 + Issue #131) - Consumer Cancel Notifications (Issue #131) - Publisher Confirms amqplib has not been updated in a long while, so maintaining our own fork ensures that we can quickly roll out new features and fixes without resorting to monkey patching. To use the py-amqp transport you must install the amqp library: $ pip install amqp and change the connection URL to use the correct transport: >>> conn = Connection('pyamqp://guest:guest@localhost//') The pyamqp:// transport will be the default fallback transport in Kombu version 3.0, when librabbitmq is not installed, and librabbitmq will also be updated to support the same features. - Connection now supports heartbeat argument. If enabled you must make sure to manually maintain heartbeats by calling the Connection.heartbeat_check at twice the rate of the specified heartbeat interval. E.g. if you have Connection(heartbeat=10),
Alexandre Rogoski
2012-07-26 00:07:12 +0000
f75df37940Accepting request 127657 from devel:languages:python
Ismail Dönmez
2012-07-12 08:51:42 +0000
523b46757d- Update to version 2.2.6: + Adds messaging.entry_to_queue for compat with previous versions. + Changes from version 2.2.5: + Pidbox: Now sets queue expire at 10 seconds for reply queues. + EventIO: Now ignores ValueError raised by epoll unregister. + MongoDB: Fixes Issue #142 - Changes from version 2.2.4: + Support for msgpack-python 0.2.0 (Issue #143) + kombu.common.maybe_declare no longer caches entities with the auto_delete flag set. + New experimental filesystem transport. + Virtual Transports: Now support anonymous queues and exchanges. - retry argument to Producer.publish now works properly, and only later bound using .revive(channel). * ProducerPool now takes Producer argument. * We now patch amqplib's __del__ method to skip trying to close the socket * The Connection.ensure methods now accepts a max_retries value A value of 0 now means *do not retry*, which is distinct from :const:None * SQS Transport: Now has a lowercase sqs alias, so that it can be This can be disabled by setting the supports_fanout transport option: * SQS: Can now set the Amazon AWS region, by using the region * amqplib: Now uses localhost as default hostname instead of raising an * amqplib transport: Now supports login_method for SSL auth.
Sascha Peilicke
2012-07-11 12:58:41 +0000
15db74aead- Update to 2.2.6: - Adds `messaging.entry_to_queue` for compat with previous versions.
Alexandre Rogoski
2012-07-10 22:42:54 +0000
d048eb114c- Update to 2.2.5: - Pidbox: Now sets queue expire at 10 seconds for reply queues. - EventIO: Now ignores `ValueError` raised by epoll unregister. - MongoDB: Fixes Issue #142 Fix by Flavio Percoco Premoli
Alexandre Rogoski
2012-07-10 16:37:51 +0000
c0acd0ee26- Update to 2.2.4: - Support for msgpack-python 0.2.0 (Issue #143) The latest msgpack version no longer supports Python 2.5, so if you're still using that you need to depend on an earlier msgpack-python version. Fix contributed by Sebastian Insua - kombu.common.maybe_declare no longer caches entities with the auto_delete flag set. - New experimental filesystem transport. Contributed by Bobby Beever. - Virtual Transports: Now support anonymous queues and exchanges.
Alexandre Rogoski
2012-07-05 16:34:18 +0000
65270b90ef- Update to 2.2.3: - BrokerConnection now renamed to Connection. The name Connection has been an alias for a very long time, but now the rename is official in the documentation as well. The Connection alias has been available since version 1.1.3, and BrokerConnection will still work and is not deprecated. - Connection.clone() now works for the sqlalchemy transport. - kombu.common.eventloop, kombu.utils.uuid, and kombu.utils.url.parse_url can now be imported from the kombu module directly. - Pidbox transport callback after_reply_message_received now happens in a finally block. - Trying to use the librabbitmq:// transport will now show the right name in the ImportError if librabbitmq is not installed. The librabbitmq falls back to the older pylibrabbitmq name for compatibility reasons and would therefore show No module named pylibrabbitmq instead of librabbitmq.
Alexandre Rogoski
2012-06-25 12:22:49 +0000
e1990d2200- Update to 2.2.1: - SQS: Default visibility timeout is now 30 minutes. Since we have ack emulation the visibility timeout is only in effect if the consumer is abrubtly terminated. - retry argument to `Producer.publish` now works properly, when the declare argument is specified. - Json serializer: didn't handle buffer objects (Issue #135). Fix contributed by Jens Hoffrichter. - Virtual: Now supports passive argument to exchange_declare. - Exchange & Queue can now be bound to connections (which will use the default channel): >>> exchange = Exchange("name") >>> bound_exchange = exchange(connection) >>> bound_exchange.declare() - SimpleQueue & SimpleBuffer can now be bound to connections (which will use the default channel). - Connection.manager.get_bindings now works for librabbitmq and pika. - Adds new transport info attributes: - Transport.driver_type Type of underlying driver, e.g. "amqp", "redis", "sql". - Transport.driver_name Name of library used e.g. "amqplib", "redis", "pymongo". - Transport.driver_version() Version of underlying library.
Alexandre Rogoski
2012-06-21 15:00:10 +0000
9424084e44Accepting request 121280 from devel:languages:python
Stephan Kulow
2012-05-21 05:30:27 +0000
8edf8e476d- Update to 2.1.8: * Bound Exchange/Queue's are now pickleable. * Consumer/Producer can now be instantiated without a channel, and only later bound using `.revive(channel). * ProducerPool now takes Producer` argument. * kombu.utils.fxrange now counts forever if the stop argument is set to None. (fxrange is like xrange but for decimals). * Auto delete support for virtual transports were incomplete and could lead to problems so it was removed. * Cached declarations (kombu.common.maybe_declare) are now bound to the underlying connection, so that entities are redeclared if the connection is lost. This also means that previously uncacheable entities (e.g. non-durable) can now be cached. * compat ConsumerSet: can now specify channel.
Alexandre Rogoski
2012-05-07 20:52:34 +0000
66a7dbe042- Update to 2.1.7: * compat consumerset now accepts optional channel argument.
Alexandre Rogoski
2012-04-27 19:00:57 +0000
5623928e6c- Update to 2.1.6: * SQLAlchemy transport was not working correctly after URL parser change. * maybe_declare now stores cached declarations per underlying connection instead of globally, in the rare case that data disappears from the broker after connection loss. * Django: Added South migrations. Contributed by Joseph Crosland.
Alexandre Rogoski
2012-04-23 14:43:37 +0000
20f9b4e1acAccepting request 114451 from devel:languages:python
Stephan Kulow
2012-04-20 13:19:41 +0000
88c90dee03- Update to 2.1.5: * The url parser removed more than the first leading slash (Issue #121). * SQLAlchemy: Can now specify url using + separator Example:: BrokerConnection("sqla+mysql://localhost/db") * Better support for anonymous queues (Issue #116). Contributed by Michael Barrett. * Connection.as_uri now quotes url parts (Issue #117). * Beanstalk: Can now set message TTR as a message property. Contributed by Andrii Kostenko
Alexandre Rogoski
2012-04-13 17:39:47 +0000
a30ab228f7- Update to 2.1.4: * MongoDB: URL parsing are now delegated to the pymongo library (Fixes Issue #103 and Issue #87). Fix contributed by Flavio Percoco Premoli and James Sullivan * SQS: A bug caused SimpleDB to be used even if sdb persistence was not enabled (Issue #108). Fix contributed by Anand Kumria. * Django: Transaction was committed in the wrong place, causing data cleanup to fail (Issue #115). Fix contributed by Daisuke Fujiwara. * MongoDB: Now supports replica set URLs. Contributed by Flavio Percoco Premoli. * Redis: Now raises a channel error if a queue key that is currently being consumed from disappears. Fix contributed by Stephan Jaekel. * All transport 'channel_errors' lists now includes kombu.exception.StdChannelError. * All kombu exceptions now inherit from a common kombu.exceptions.KombuError.
Alexandre Rogoski
2012-04-10 16:20:15 +0000
17271b8000- Change rabbitmq-server recommends to suggests, OpenStack doesn't like that - Simplified macro usage - Use upstream tarball
Sascha Peilicke
2012-03-27 08:40:08 +0000
8700ecce4a- Update to version 2.1.1: * Connection URLs now supports encoded characters. * Fixed a case where connection pool could not recover from connection loss. * We now patch amqplib's `__del__` method to skip trying to close the socket if it is not connected, as this resulted in an annoying warning. * Compression can now be used with binary message payloads. - Don't install INSTALL - Run testsuite
Sascha Peilicke
2012-03-10 17:07:06 +0000
337f9608cdAccepting request 103931 from devel:languages:python
Stephan Kulow
2012-02-17 11:08:48 +0000
83882cee05- Update to 2.1.0: * MongoDB: Now supports fanout (broadcast) (Issue #98). Contributed by Scott Lyons. * pika transport: Now works with pika 0.9.5 and 0.9.6dev. The old pika transport (supporting 0.5.x) is now available as alias oldpika. (Note terribly latency has been experienced with the new pika versions, so this is still an experimental transport).
Alexandre Rogoski
2012-02-04 18:05:55 +0000
d54965ec0f- Update to 2.0.0: Important Notes - No longer supports Python 2.4. New Transports - django-kombu is now part of Kombu core. - kombu-sqlalchemy is now part of Kombu core. News - kombu.mixins.ConsumerMixin is a mixin class that lets you easily write consumer programs and threads. - SQS Transport: Added support for SQS queue prefixes (Issue #84). - Producer.publish now supports automatic retry. - Producer.publish now supports a declare keyword argument. Fixes - Redis transport: Timeout was multiplied by 1000 seconds when using select for event I/O (Issue #86).
Alexandre Rogoski
2012-01-17 01:18:47 +0000
ccec8e0c0a- Update to 1.5.1: * Fixes issue with kombu.compat introduced in 1.5.0 (Issue #83). * Adds the ability to disable content_types in the serializer registry.
Alexandre Rogoski
2011-11-30 14:56:34 +0000
b40d3c271a- Update to 1.5.0: * kombu.pools: Fixed a bug resulting in resources not being properly released. This was caused by the use of __hash__ to distinguish them. * Virtual transports: Dead-letter queue is now disabled by default. The dead-letter queue was enabled by default to help application authors, but now that Kombu is stable it should be removed. There are after all many cases where messages should just be dropped when there are no queues to buffer them, and keeping them without supporting automatic cleanup is rather considered a resource leak than a feature. If wanted the dead-letter queue can still be enabled, by using the deadletter_queue transport option: >>> x = BrokerConnection("redis://", ... transport_options={"deadletter_queue": "ae.undeliver"}) In addition, an UndeliverableWarning is now emitted when the dead-letter queue is enabled and a message ends up there. * MongoDB transport now supports Replicasets (Issue #81). * The Connection.ensure` methods now accepts a max_retries value of 0. A value of 0 now means *do not retry*, which is distinct from :const:None which means *retry indefinitely*. * SQS Transport: Now has a lowercase sqs alias, so that it can be used with broker URLs (Issue #82). * SQS Transport: Fixes KeyError on message acknowledgements (Issue #73). The SQS transport now uses UUID's for delivery tags, rather than a counter. * SQS Transport: Unicode related fixes (Issue #82). * Redis version check could crash because of improper handling of types (Issue #63). * Fixed error with Resource.force_close_all, when resources
Alexandre Rogoski
2011-11-28 02:28:28 +0000
49b3c4c8c8Accepting request 93425 from devel:languages:python
Stephan Kulow
2011-11-25 10:13:14 +0000
c99e61b73c- Set license to SPDX style (BSD-2-Clause) - Removed outdated %clean section
Sascha Peilicke
2011-11-24 11:39:42 +0000
f985f88490- Update to 1.4.3: - Fixes bug in ProducerPool where too many resources would be acquired.
Alexandre Rogoski
2011-10-27 22:33:54 +0000
f89e389f98- Update to 1.4.2: - Eventio: Polling should ignore errno.EINTR - SQS: str.encode did only start accepting kwargs after Py2.7. - simple_task_queue example didn’t run correctly (Issue #72). - Empty messages would not raise an exception not able to be handled by on_decode_error (Issue #72) - CouchDB: Properly authenticate if user/password set (Issue #70) - BrokerConnection.Consumer had the wrong signature.
Alexandre Rogoski
2011-10-26 18:18:43 +0000
e16065ad07- Update to 1.4.1: - 1.4.0 broke the producer pool, resulting in new connections being established for every acquire.
Alexandre Rogoski
2011-09-26 18:48:26 +0000
ad43ea6e20- Update to 1.4.0: - Adds module kombu.mixins. - New example: Task Queue Example - MongoDB transport did not work with MongoDB >= 2.0 (Issue #66) - Redis-py version check did not account for beta identifiers in version string. - Producer and Consumer now accepts a connection instance as the first argument. - BrokerConnection has aquired a connected attribute that can be used to check if the connection instance has established a connection. - ConnectionPool.acquire_channel now returns the connections default channel rather than establising a new channel that must be manually handled. - Added kombu.common.maybe_declare - kombu.compat.entry_to_queue() has been moved to kombu.common - New module kombu.clocks now contains an implementation of Lamports logical clock.
Alexandre Rogoski
2011-09-22 17:05:09 +0000
Denisart Benjamin
Stephan Kulow
Sascha Peilicke
Tomáš Chvátal
Todd R
Alexandre Rogoski
Ismail Dönmez