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

81 Commits

Author SHA1 Message Date
David Gelvin 0e35cec74f Include requeue=False when rejecting a message 2010-10-05 20:13:57 +03:00
Ask Solem 0cd4e6832f Bumped version to 0.2.0 2010-09-20 09:46:10 +02:00
Ask Solem 130c8c3cce Fix broken unicode test for Py 2.4 2010-09-17 09:01:07 +02:00
Ask Solem 56c2eb0966 Added kombu.utils.functional.wraps for Py 2.4 compatibility. 2010-09-16 16:28:37 +02:00
Ask Solem 88eff095e2 test_functional.test_amqplib: test_produce__consume_multiple: Make sure queues are declared before doing the purge. 2010-09-16 16:24:46 +02:00
Ask Solem 5d3475736e Functional tests for pyamqplib are passing again 2010-09-16 16:15:10 +02:00
Ask Solem 5ea899d035 Changes my author e-mail to ask@celeryproject.org 2010-08-20 13:44:58 +02:00
Ask Solem 1cb387b338 Merge branch 'nvie/master' 2010-08-13 13:19:37 +02:00
Ask Solem d6b0c84194 Use set.discard instead of set.remove 2010-08-13 13:19:28 +02:00
Vincent Driessen 396f0e9078 Update dependencies for building RPM's. 2010-08-13 11:54:23 +02:00
Ask Solem 55c72cce04 Fixed typo in docstring 2010-08-13 11:46:14 +02:00
Ask Solem af2790222e Split simple userguide in two: connections and simple 2010-08-05 18:16:02 +02:00
Ask Solem b5ee26f245 Release tools 2010-08-05 18:15:36 +02:00
Ask Solem 4c16dbbeb3 UserGuide: Simple: Fixed typos 2010-08-04 15:51:54 +02:00
Ask Solem 014b1159f4 Docs: Added autodoc for kombu.compression + kombu.simple 2010-08-04 15:51:25 +02:00
Ask Solem 40d447e806 Some more typos 2010-08-04 15:36:00 +02:00
Ask Solem 2960bb4e93 Fixed rst errors 2010-08-04 15:31:10 +02:00
Ask Solem 52e72dbb1b Forgot to add autodoc for kombu.transport.virtual 2010-08-04 15:30:00 +02:00
Ask Solem d82bc237a7 Documentation: Started writing the User Guide 2010-08-04 15:20:12 +02:00
Ask Solem fd0296af7b All occurences of the term Backend has been replaced with Transport. 
kombu.backends -> kombu.transport
BrokerConnection(backend_cls="pika") -> BrokerConnection(transport="pika")
kombu.backends.base.BaseBackend -> kombu.transport.base.Transport
kombu.backends.pyredis.RedisBackend -> kombu.transport.pyredis.Transport
etc, etc.
 2010-08-04 13:53:43 +02:00
Ask Solem df3d885cd7 Fixed typo 2010-08-04 13:26:43 +02:00
Ask Solem 985a1f025f Some typos in Connection.ensure 2010-08-04 08:33:48 +02:00
Ask Solem 4b2f4d47e4 Fixed typo form -> from 2010-08-02 12:41:42 +02:00
Ask Solem 1492b7c689 amqplib's handshake mistakenly identifies as protocol version 1191, 
this breaks in RabbitMQ tip, which no longer falls back to
0-8 for unknown ids.
 2010-08-02 12:39:09 +02:00
Ask Solem a3f67ffce8 amqplib backend: Support for mandatory/immediate (basic_return) callbacks. 
Example usage::

    from time import sleep

    from kombu import BrokerConnection, Producer, Exchange

    e = Exchange("mcasdsada")

    conn = BrokerConnection()
    chan = conn.channel()

    def return_callback(exc, exchange, routing_key, message):
        print("%r: %s" % (exc, message))

    p = Producer(chan, e, on_return=return_callback)
    p.publish({"foo": "bar"}, immediate=True, routing_key="akka")

    for i in range(5):
        conn.drain_events()
        sleep(0.1)

Note that the events must be drained for the callback to be called,
the solution to support this for synchronous use is still a challenge.
 2010-08-01 23:31:10 +02:00
Ask Solem 7385724268 kombu.simple.SimpleQueue + SimpleBuffer: Simple queueing interface. 2010-08-01 17:09:05 +02:00
Ask Solem 0e4afa2f29 backends.virtual.Consumer renamed to FairCycle 2010-08-01 17:08:45 +02:00
Ask Solem ba262e6f70 Added kombu.messaging.Producer.compression attribute. 2010-08-01 17:08:21 +02:00
Ask Solem 3c96d0affe kombu.Binding has been renamed to kombu.Queue 2010-08-01 11:41:03 +02:00
Ask Solem 3f4248a80c unittests passing again 2010-07-31 16:41:35 +02:00
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