summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* In-progress webserver: To be used as an in-memory broker, or proxy to ↵webserverAsk Solem2010-08-051-0/+194
| | | | another broker.
* Split simple userguide in two: connections and simpleAsk Solem2010-08-053-38/+42
|
* Release toolsAsk Solem2010-08-051-0/+39
|
* UserGuide: Simple: Fixed typosAsk Solem2010-08-041-9/+7
|
* Docs: Added autodoc for kombu.compression + kombu.simpleAsk Solem2010-08-043-0/+24
|
* Some more typosAsk Solem2010-08-042-9/+8
|
* Fixed rst errorsAsk Solem2010-08-042-2/+2
|
* Forgot to add autodoc for kombu.transport.virtualAsk Solem2010-08-041-0/+11
|
* Documentation: Started writing the User GuideAsk Solem2010-08-044-2/+173
|
* All occurences of the term Backend has been replaced with Transport.Ask Solem2010-08-0425-157/+148
| | | | | | | | 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.
* Fixed typoAsk Solem2010-08-041-2/+2
|
* Some typos in Connection.ensureAsk Solem2010-08-042-3/+11
|
* Fixed typo form -> fromAsk Solem2010-08-021-1/+1
|
* amqplib's handshake mistakenly identifies as protocol version 1191,Ask Solem2010-08-021-0/+6
| | | | | this breaks in RabbitMQ tip, which no longer falls back to 0-8 for unknown ids.
* amqplib backend: Support for mandatory/immediate (basic_return) callbacks.Ask Solem2010-08-012-2/+31
| | | | | | | | | | | | | | | | | | | | | | | | | | 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.
* kombu.simple.SimpleQueue + SimpleBuffer: Simple queueing interface.Ask Solem2010-08-012-0/+161
|
* backends.virtual.Consumer renamed to FairCycleAsk Solem2010-08-011-4/+4
|
* Added kombu.messaging.Producer.compression attribute.Ask Solem2010-08-011-4/+13
|
* kombu.Binding has been renamed to kombu.QueueAsk Solem2010-08-019-154/+159
|
* unittests passing againAsk Solem2010-07-315-15/+28
|
* Added support for automatic compression/decompression of messages.Ask Solem2010-07-313-6/+54
| | | | | | | | | | | | | | | | | | | | | | | | | | | | 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")
* Fixed typo message_data -> bodyAsk Solem2010-07-311-1/+1
|
* amqplib backend: Properly support Message.properties + Message.headersAsk Solem2010-07-311-12/+11
|
* Documented kombu.messagingAsk Solem2010-07-282-41/+223
|
* BrokerConnectionPool.acquire now has block and timeout argumentsAsk Solem2010-07-232-50/+128
|
* Documented BrokerConnectionAsk Solem2010-07-232-9/+130
|
* Added celery theme to documentationAsk Solem2010-07-2320-1019/+429
|
* Renamed Exchange.create_message -> Exchange.MessageAsk Solem2010-07-231-6/+6
|
* Documented kombu.entity, Exchange + BindingAsk Solem2010-07-231-10/+344
|
* Redis: Maintain exception listsAsk Solem2010-07-231-1/+3
|
* Added Sphinx DocumentationAsk Solem2010-07-2334-32/+1623
|
* Experimental pool and "ensure operation succeds" features.Ask Solem2010-07-232-47/+221
|
* Backends: self.connection renamed to self.client, makes it easier to ↵Ask Solem2010-07-236-15/+84
| | | | distinguish from the underlying connection
* Added Sean Bleier to AUTHORSAsk Solem2010-07-231-0/+1
|
* Small typosebleier2010-07-221-17/+17
|
* Fixed mock Backend drain_events method to have the same number arguments as ↵sebleier2010-07-221-1/+1
| | | | the real backend
* Removed connection argument, since the connection already exists on the channelsebleier2010-07-221-1/+1
|
* Removed some carrot referencesv0.1.0Ask Solem2010-07-222-26/+4
|
* Updated ChangelogAsk Solem2010-07-221-1/+3
|
* Set version to 0.1.0Ask Solem2010-07-222-4/+6
|
* PEP8ify + pyflakesAsk Solem2010-07-223-10/+7
|
* Added some stuff to .gitignoreAsk Solem2010-07-221-0/+4
|
* Added pavement.pyAsk Solem2010-07-221-0/+147
|
* Pika backend is workingAsk Solem2010-07-221-25/+52
|
* Instantiating a Consumer does not declare consumer. Use Consumer.consume()Ask Solem2010-07-222-12/+19
|
* Added the ability to do binding.queue_declare(passive=True) to get queue status.Ask Solem2010-07-221-13/+19
|
* Renamed kombu.backends.emulation -> kombu.backends.virtualAsk Solem2010-07-224-13/+11
|
* Added nowait + refactored away assert_is_bound thingAsk Solem2010-07-224-56/+49
|
* Exchange.routing_key removed and moved to Producer.routing_key.Ask Solem2010-07-222-8/+7
| | | | Makes more sense.
* Redis backend working with _get_manyAsk Solem2010-07-212-13/+12
|
View Lorry Controller Status