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

245 Commits

Author SHA1 Message Date
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
Ask Solem 824a4bf59e repr(BrokerConnection) now shows connection URI 2011-01-12 13:37:11 +01:00
Ask Solem b3f005e3e2 Adds BrokerConnection.as_uri(). Moved from Celery to Kombu 2011-01-12 12:01:02 +01:00
Ask Solem 85112484d6 Bumped version to 1.0.0b4 2011-01-07 13:40:38 +01:00
Ask Solem f2ed5a67f2 connection.ensure now raises the original exception instead EnsureExhausted when max retries exceeded 2011-01-07 13:40:25 +01:00
Ask Solem 4c463808f7 Fixed serious error in fxrange introduced today 2011-01-07 13:31:40 +01:00
Ask Solem 39b1c5c81d pyflakes 2011-01-07 11:30:13 +01:00
Ask Solem a134ae0ff3 Bumped version to 1.0.0b3 2011-01-07 11:28:37 +01:00
Ask Solem eed34140ae tests didn't pass fxrange 2011-01-07 11:22:05 +01:00
Ask Solem 387e979840 Implement connection revive() for kombu.compat classes 2011-01-07 11:11:22 +01:00
Ask Solem dabfcbadf8 connection.ensure_* interval arguments can now be float 2011-01-07 11:08:58 +01:00
Ask Solem 8122d03e51 Added Rob Ottaway to AUTHORS 2011-01-06 13:28:38 +01:00
Ask Solem 1d389f0355 Merge branch 'robottaway/master' 2011-01-06 13:28:12 +01:00
Ask Solem d50b27f160 Bumped version to 1.0.0b2 2011-01-03 13:45:16 +01:00
Ask Solem f302d81461 Use pure-python pickle on Python <= 2.5, as cPickle is broken there 2011-01-03 13:44:40 +01:00
Rob Ottaway a60da56e18 Fixing missing headers issue 2010-12-21 11:01:25 -08:00
Ask Solem 6d9cdf3830 Added Alexandre Bourget to AUTHORS 2010-12-21 10:23:53 +01:00
Alexandre Bourget ed67ff1966 Just fix a missing "import" 2010-12-20 14:50:44 -05:00
Ask Solem 857bd4e2cd PEP8ify 2010-12-18 11:52:25 +01:00
Ask Solem 130823fa14 Bumped version to 1.0.0b1 2010-12-18 11:49:40 +01:00
Ask Solem b5f92c4929 Since virtual broker state is now global, so must the Redis server mock be 2010-12-07 16:05:06 +01:00
Ask Solem 5494317a04 pika: channel.connection must be available (in pika it's channel.handler.connection) 2010-12-05 15:12:46 +01:00
Ask Solem f202a35b25 Fixed typo in setup.py 2010-12-03 14:22:04 +01:00
Ask Solem 5256b2a4e6 BrokerState must be global, otherwise declarations will be lost from connection to connection. 2010-12-03 14:16:43 +01:00
Ask Solem 2bf695de2f Unit tests now passing on Python 3 2010-12-03 12:55:41 +01:00
Ask Solem dec4d12d42 Py3k Support 2010-12-02 15:32:26 +01:00
Ask Solem eb7748d27b 2to3 says we should use a for loop here 2010-12-02 15:24:35 +01:00
Ask Solem 97ac8b077c Added eventlet examles: examples/simple_eventlet_receive.py simple_eventlet.send.py 2010-12-01 12:28:31 +01:00
Ask Solem b6d679fe34 Added SimpleQueue examples: examples/simple_receive.py, simple_send.py 2010-12-01 12:28:10 +01:00
Ask Solem 8ebbbd3ac8 Fixed SimpleQueue.get if there was no timeout specified 2010-12-01 12:27:31 +01:00
Ask Solem aa5ee5c436 PEP8ifye 2010-11-30 19:58:04 +01:00
Ask Solem 0e44a16230 Bumped version to 0.9.7 2010-11-30 19:56:39 +01:00
Ask Solem a574515aa9 Allow connection pools with no limit 2010-11-30 19:56:12 +01:00
Ask Solem c86ced6746 Remove useless try: else: 2010-11-29 22:53:45 +01:00
Ask Solem 586faacdf9 msgpack content-encoding must be 'binary' not 'utf-8' 2010-11-25 16:13:40 +01:00
Ask Solem 4ee6495431 ADded Falvio Percoco Premoli, David Clymer and David Ziegler to AUTHORS 2010-11-24 13:29:45 +01:00