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

285 Commits

Author SHA1 Message Date
Ask Solem 5eac1a8643 Adds Anton Gyllenberg to AUTHORS 2011-01-29 13:32:33 +01:00
Anton Gyllenberg 7e51ce301a Correctly pass properties to amqp.Message() 
Fix transport.pyamqlib.Channel.prepare_message() to correctly
pass properties to amqp.Message(). amqp.Message() takes properties
as separate keyword arguments. Before this fix, prepare_message()
passed the properties as a dict in a single argument 'properties',
which was ignored by amqp.Message().

This issue has serious consequences. For example, as the 'delivery_mode'
property is dropped, all messages will be transient even if the documented
default is persistent and even if 'delivery_mode' is explicitely set
to persistent.
 2011-01-29 08:47:33 +02:00
Ask Solem 572e709f9c Documentation fixes 2011-01-28 22:45:20 +01:00
Ask Solem a9b53e89bc Fixed typo client -> c 2011-01-28 20:31:12 +01:00
Ask Solem c39bf4606c Bumped version to 1.0.1 and updated Changelog 2011-01-28 20:28:39 +01:00
Ask Solem 45e0086aed Redis: Adds missing method _handle_message 2011-01-28 15:45:51 +01:00
Ask Solem 495fd9cba4 epoll.poll timeout can't be None, use -1 for infinity 2011-01-28 12:34:07 +01:00
Ask Solem b7b625e0d8 eventio.epoll: Don't convert None to float 2011-01-28 11:49:10 +01:00
Ask Solem 008624b788 with Consumer() now works 2011-01-27 15:26:23 +01:00
Ask Solem 8cebb41955 Added connection.Pool.acquire_channel context manager. 2011-01-27 15:22:43 +01:00
Ask Solem 33a4a8579b Version 1.0.0 2011-01-27 11:46:50 +01:00
Ask Solem 9bcbdd7977 PEP8ify 2011-01-27 11:46:29 +01:00
Ask Solem 56aa7fa21b Load kombu root module lazily 2011-01-27 11:40:47 +01:00
Ask Solem 9c17749769 Import SimpleQueue/SimpleBuffer lazily 2011-01-27 11:40:30 +01:00
Ask Solem b9a0b59590 kombu.utils.blocking renamed -> kombu.syn.blocking 2011-01-27 11:40:15 +01:00
Ask Solem a92d125f09 Fixed typo __init___ -> __init__ 2011-01-26 13:10:26 +01:00
Ask Solem 936ea9f5f1 epoll: Ignore socket.errors on _epoll.unregister 2011-01-26 13:03:44 +01:00
Ask Solem 5d4110190d Tests passing on Jython 2011-01-25 13:54:59 +01:00
Ask Solem 3f28abcb58 gevent: Make sure synchronous calls are blocking 2011-01-25 12:54:22 +01:00
Ask Solem 4b50b6ba38 PEP8ify 2011-01-25 12:38:03 +01:00
Ask Solem 7aa313f61d Added autodoc for librabbitmq transport 2011-01-25 12:37:56 +01:00
Ask Solem 2774c4c672 eventio: epoll timeout is float not ms 2011-01-25 12:33:45 +01:00
Ask Solem 4f4b872d05 Added librabbitmq transport (requires librabbitmq-c + pylibrabbitmq) 2011-01-24 13:40:34 +01:00
Ask Solem f52511289a The bz2 module does not exist on Jython 2011-01-23 14:28:05 +01:00
Ask Solem 499a6445eb Added compiled jython files to gitignore 2011-01-23 14:27:52 +01:00
Ask Solem 60fad47bd9 Eventlet: Make sure synchronous methods are blocking 2011-01-23 01:51:01 +01:00
Ask Solem 529cb0fc33 Last change made test invalid 2011-01-21 12:19:18 +01:00
Ask Solem 2d08e34e50 virtual: must continue draining events even if no channels (yet) registered 2011-01-21 10:27:41 +01:00
Ask Solem 9689ea75af rst in README was broken 2011-01-21 10:13:10 +01:00
Ask Solem 025f5fda3e README.rst can't contain unicode (because of PyPI upload) 2011-01-20 12:20:16 +01:00
Ask Solem 0137df7f73 Bumped version to 1.0.0rc3 2011-01-20 12:19:13 +01:00
Ask Solem f609fb1621 Ignore autodoc for kombu.utils.eventio 2011-01-20 12:18:27 +01:00
Ask Solem 67fc107396 Cleanup 2011-01-20 12:17:24 +01:00
Ask Solem ab9f5eec51 Passes all tests again 2011-01-20 12:01:40 +01:00
Ask Solem f16621fe8f Merge branch 'master' into redis_epoll_consume 2011-01-19 21:20:15 +01:00
Ask Solem 27983aa776 Tests passes again. Thanks to salmon_ 2011-01-19 13:44:39 +01:00
Ask Solem 501669fed3 amqplib: Set connection.client 2011-01-18 21:39:56 +01:00
Ask Solem eab0680398 conn.SimpleQueue/SimpleBuffer: Pass kwargs 2011-01-18 21:39:06 +01:00
Ask Solem d199df249c Cosmetics 2011-01-18 21:38:09 +01:00
Ask Solem 9f7f71f586 kqueue accidentally disabled 2011-01-18 12:03:38 +01:00
Ask Solem df265a49aa remove left-over print statement 2011-01-18 11:53:38 +01:00
Ask Solem 65f1174d83 Redis: Consume now works with Eventlet 2011-01-18 11:52:59 +01:00
Ask Solem 1ade2c8d2b Cleanup 2011-01-18 11:09:58 +01:00
Ask Solem 2cb7c11a59 Added transport comparison table 2011-01-18 09:20:13 +01:00
Ask Solem abd25e9dca Redis: Improved solution to drain_events (no longer needs threads), and using PUBLISH/SUBSCRIBE for broadcast exchanges! 
Using epoll/kpoll/select to poll several Redis connections at once instead
of having one thread for each channel.

These changes drastically improves the responsitivity of both store-and-forward and
broadcast messaging using Redis.  While the previous solution could have a
latency of 1 second per message, this solution can receive broadcast command
and send reply in ~0.006 seconds (~realtime)
 2011-01-17 16:33:58 +01:00
Ask Solem 08ee10243b FairCycle.get: Forward kwargs to callback 2011-01-17 16:33:35 +01:00
Ask Solem 8b09417dff Keeps track of active_queues, instead of generating it need 2011-01-17 16:32:57 +01:00
Ask Solem 61eb2a0fb4 Added ExchangeType.type for the name of the exchange type 2011-01-17 16:32:20 +01:00
Ask Solem 12808079ba pidbox: Declare reply exchange when sending reply 2011-01-17 16:31:38 +01:00
Ask Solem dfa1b37fac Redis: Uses epoll/kqueue/select to consume from multiple connections at once 2011-01-15 16:33:02 +01:00