Skip to content
Commits on Aug 13, 2010
  1. Fixed typo in docstring

    Ask Solem committed Aug 13, 2010
Commits on Aug 5, 2010
  1. Release tools

    Ask Solem committed Aug 5, 2010
Commits on Aug 4, 2010
  1. UserGuide: Simple: Fixed typos

    Ask Solem committed Aug 4, 2010
  2. Some more typos

    Ask Solem committed Aug 4, 2010
  3. Fixed rst errors

    Ask Solem committed Aug 4, 2010
  4. Forgot to add autodoc for kombu.transport.virtual

    Ask Solem committed Aug 4, 2010
  5. Documentation: Started writing the User Guide

    Ask Solem committed Aug 4, 2010
  6. All occurences of the term Backend has been replaced with Transport.

    Ask Solem committed Aug 4, 2010
    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.
  7. Fixed typo

    Ask Solem committed Aug 4, 2010
  8. Some typos in Connection.ensure

    Ask Solem committed Aug 4, 2010
Commits on Aug 2, 2010
  1. Fixed typo form -> from

    Ask Solem committed Aug 2, 2010
  2. amqplib's handshake mistakenly identifies as protocol version 1191,

    Ask Solem committed Aug 2, 2010
    this breaks in RabbitMQ tip, which no longer falls back to
    0-8 for unknown ids.
Commits on Aug 1, 2010
  1. amqplib backend: Support for mandatory/immediate (basic_return) callb…

    Ask Solem committed Aug 1, 2010
    …acks.
    
    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.
  2. backends.virtual.Consumer renamed to FairCycle

    Ask Solem committed Aug 1, 2010
  3. kombu.Binding has been renamed to kombu.Queue

    Ask Solem committed Aug 1, 2010
Commits on Jul 31, 2010
  1. unittests passing again

    Ask Solem committed Jul 31, 2010
  2. Added support for automatic compression/decompression of messages.

    Ask Solem committed Jul 31, 2010
    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")
  3. Fixed typo message_data -> body

    Ask Solem committed Jul 31, 2010
Commits on Jul 28, 2010
  1. Documented kombu.messaging

    Ask Solem committed Jul 28, 2010
Commits on Jul 23, 2010
  1. Documented BrokerConnection

    Ask Solem committed Jul 23, 2010
  2. Added celery theme to documentation

    Ask Solem committed Jul 23, 2010
  3. Renamed Exchange.create_message -> Exchange.Message

    Ask Solem committed Jul 23, 2010
  4. Documented kombu.entity, Exchange + Binding

    Ask Solem committed Jul 23, 2010
  5. Redis: Maintain exception lists

    Ask Solem committed Jul 23, 2010
  6. Added Sphinx Documentation

    Ask Solem committed Jul 23, 2010
  7. Backends: self.connection renamed to self.client, makes it easier to …

    Ask Solem committed Jul 23, 2010
    …distinguish from the underlying connection
Commits on Jul 22, 2010
  1. Added Sean Bleier to AUTHORS

    Ask Solem committed Jul 23, 2010
Something went wrong with that request. Please try again.