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

280 Commits

Author SHA1 Message Date
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
Ask Solem aad945d3a5 Cosmetics 2011-01-14 16:44:19 +01:00
Ask Solem 6a4862b288 Added Resource.force_close_all 2011-01-14 11:39:07 +01:00
Ask Solem 5ec28c9115 Bumped version to 1.0.0rc2 2011-01-13 15:41:58 +01:00
Ask Solem 4c7cdc875e message_data -> body 2011-01-12 15:48:53 +01:00
Ask Solem f1a8dfdba4 Bumped version to 1.0.0rc1 2011-01-12 13:38:59 +01:00