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

1901 Commits

Author SHA1 Message Date
Ask Solem c5cb3a9c59 Added support for automatic compression/decompression of messages. 
This is done by adding the "compression" header to messages.
Currently supported compression formats are: zlib and bzip2.
Custom compression formats can be added using kombu.compression.register::

    >>> compression.register(encoder, decoder, content_type, aliases={})

e.g.::

    >>> compression.register(lambda x: x.encode("zlib"),
    ...                      lambda x: x.decode("zlib"),
    ...                      "application/x-zlib",
    ...                      aliases=["zlib", "gzip"])

To enable compression you use the ``compression`` argument to
:meth:`Producer.publish`. When these messages are then consumed by
kombu they will be automatically decompressed, other clients need to
decompress them manually by looking at the ``compression`` header.

Example using zlib compression:

    >>> producer.publish(message, serializer="json", compression="zlib")

Example using bzip2 compression:

    >>> producer.publish(message, serializer="json", compression="bz2")
 2010-07-31 14:26:55 +02:00
Ask Solem c0b540af69 Fixed typo message_data -> body 2010-07-31 14:26:20 +02:00
Ask Solem 46bd38757b amqplib backend: Properly support Message.properties + Message.headers 2010-07-31 14:25:53 +02:00
Ask Solem 4c9ac1436e Documented kombu.messaging 2010-07-28 19:25:32 +02:00
Ask Solem 3fbbbe5c6a BrokerConnectionPool.acquire now has block and timeout arguments 2010-07-23 20:28:15 +02:00
Ask Solem a67206541b Documented BrokerConnection 2010-07-23 15:57:05 +02:00
Ask Solem cd2022670f Added celery theme to documentation 2010-07-23 15:12:49 +02:00
Ask Solem ad45115c0e Renamed Exchange.create_message -> Exchange.Message 2010-07-23 14:44:33 +02:00
Ask Solem 4b0d4267d8 Documented kombu.entity, Exchange + Binding 2010-07-23 14:44:15 +02:00
Ask Solem 178bc8cde2 Redis: Maintain exception lists 2010-07-23 14:43:46 +02:00
Ask Solem 621b77a92a Added Sphinx Documentation 2010-07-23 14:43:33 +02:00
Ask Solem 6105ec7473 Experimental pool and "ensure operation succeds" features. 2010-07-23 13:42:15 +02:00
Ask Solem 209b1f333c Backends: self.connection renamed to self.client, makes it easier to distinguish from the underlying connection 2010-07-23 10:37:13 +02:00
Ask Solem 4b70908972 Added Sean Bleier to AUTHORS 2010-07-23 00:13:59 +02:00
sebleier f33d57dea7 Small typo 2010-07-22 13:10:41 -07:00
sebleier a8f33f15f2 Fixed mock Backend drain_events method to have the same number arguments as the real backend 2010-07-22 12:42:58 -07:00
sebleier 7ecbe1fae2 Removed connection argument, since the connection already exists on the channel 2010-07-22 12:27:33 -07:00
Ask Solem 4dc37d70d9 Removed some carrot references 2010-07-22 16:23:31 +02:00
Ask Solem e338b1d2ed Updated Changelog 2010-07-22 16:20:38 +02:00
Ask Solem 54912c2a0c Set version to 0.1.0 2010-07-22 16:19:46 +02:00
Ask Solem c6e033bc76 PEP8ify + pyflakes 2010-07-22 16:18:49 +02:00
Ask Solem 5bad838982 Added some stuff to .gitignore 2010-07-22 16:14:29 +02:00
Ask Solem 63e8bfbc1b Added pavement.py 2010-07-22 16:14:03 +02:00
Ask Solem 7f68477c20 Pika backend is working 2010-07-22 16:10:26 +02:00
Ask Solem d380f7cea8 Instantiating a Consumer does not declare consumer. Use Consumer.consume() 2010-07-22 16:09:58 +02:00
Ask Solem cc08721c01 Added the ability to do binding.queue_declare(passive=True) to get queue status. 2010-07-22 16:06:25 +02:00
Ask Solem 7fdd345827 Renamed kombu.backends.emulation -> kombu.backends.virtual 2010-07-22 13:55:45 +02:00
Ask Solem e501c10bb5 Added nowait + refactored away assert_is_bound thing 2010-07-22 13:55:16 +02:00
Ask Solem a1dcde8f6a Exchange.routing_key removed and moved to Producer.routing_key. 
Makes more sense.
 2010-07-22 11:30:36 +02:00
Ask Solem e74742473c Redis backend working with _get_many 2010-07-21 16:17:03 +02:00
Ask Solem 128ea635e8 Redis backend (basic testing with celery works) 2010-07-21 16:07:45 +02:00
Ask Solem 2ff8ffc4a4 Emulation backend implemented with In-memory backend as the first example. 2010-07-21 13:52:47 +02:00
Ask Solem 61237a1fc1 Small bugfixes here and there discovered by running the celery tests. 2010-07-21 12:29:08 +02:00
Ask Solem 90eaf27f85 Carrot compat interface now working with celery 2010-07-20 16:14:45 +02:00
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