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

323 Commits

Author SHA1 Message Date
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
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