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

287 Commits

Author SHA1 Message Date
Ask Solem 2e6759f4d1 Added David Gelvin to AUTHORS 2010-10-06 09:15:59 +02:00
Ask Solem 36dd024386 Merge branch 'dgelvin/master' 
Conflicts:
	kombu/messaging.py
 2010-10-06 09:14:49 +02:00
Ask Solem 801c108b43 messaging.Consumer: Add the ability to add/remove consumers at runtime 2010-10-06 09:12:29 +02:00
David Gelvin 1e0f46a5e4 Set _consuming to True after consume 2010-10-05 23:09:54 +03:00
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
Shane Caraveo 04b9a6f2fb amqp style routing for virtual exchanges (e.g. memory backend) 
forgot to git add this part of the change
 2010-09-06 15:41:02 -07:00
Shane Caraveo f8ee383cc3 add amqp style routing for virtual channels, allows memory 
backend to behave like amqp
 2010-09-06 13:56:09 -07: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