Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity
567 Commits 42 Branches 180 Tags 25 MiB
Commit Graph

567 Commits

Author SHA1 Message Date
Ask Solem 58e0c08146 cosmetics 2010-07-20 16:14:38 +02:00
Ask Solem f3d832fc3d Disabled pika tests 2010-07-20 16:13:05 +02:00
Ask Solem f752d62448 Draft pika backend 2010-07-20 16:12:50 +02:00
Ask Solem 1d22713ce6 kombu.compat: Carrot compatible interface to Kombu 
To use, replace:

    from carrot.connection import BrokerConnection
    from carrot.messaging import Publisher, Consumer

with:

    from kombu.connection import BrokerConnection
    from kombu.compat import Publisher, Consumer
 2010-07-20 15:00:39 +02:00
Ask Solem d8602b1415 README: Fixed typo Connection -> BrokerConnection 2010-07-20 15:00:17 +02:00
Ask Solem 71a8d2f39f Added tox.ini 2010-07-20 12:41:36 +02:00
Ask Solem 810828a0d7 contrib/requirements/test.txt: Added unittest2 + pika 2010-07-20 12:38:59 +02:00
Ask Solem ed6f687046 Added .gitignore 2010-06-29 21:12:46 +02:00
Ask Solem 470a269396 Update README 2010-06-29 21:12:29 +02:00
Ask Solem ddb17c7cc6 Some simple refactoring 2010-06-29 17:44:24 +02:00
Ask Solem 3149a84d18 Got 93% coverage 2010-06-29 17:31:56 +02:00
Ask Solem 87913821bb Unittests for kombu.connection 2010-06-29 00:54:13 +02:00
Ask Solem 9a4074b568 Added unittets for kombu.entities (Exchange/Binding) 2010-06-28 23:29:40 +02:00
Ask Solem db24c9d1f7 Exchange/Binding can now be bound to a channel, 
No longer have to specify the channel for each operation,
but instead do:

    >>> exchange = Exchange("foo", "direct", channel=channel)
    >>> exchange.declare()

instead of:

    >>> exchange.declare(channel)

As the Exchange/Binding classes is also the specification of an
exchange/binding these instances can be unbound, meaning they
are not associated with a channel. An entity can be bound
the a channel at any time, usually this means creating a copy
of the instance so the original is not affected::

    >>> exchange = Exchange("foo", "direct")

    >>> bound_exchange = exchange.bind(channel)
    >>> bound_exchange.declare()
    >>> bound_exchange.delete()

    >>> assert exchange is not bound_exchange
 2010-06-28 21:47:53 +02:00
Ask Solem 5325098a52 Added support for optional Consumer.on_decode_error callback 
Was patched in by Celery, much better to have it in kombu itself
 2010-06-28 21:40:03 +02:00
Ask Solem fe5074208d Added API to readme 2010-06-23 12:10:02 +02:00
Ask Solem da3e754594 Initial import 2010-06-23 12:08:39 +02:00