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

1914 Commits

Author SHA1 Message Date
Brian Bouterse d700e464de Basic qpid transport for kombu. somewhat working... 
Working:
1. Celery worker will start and run
2. Transport supports queue and exchange management operations
3. Dispatch using delay() dispatches
4. The worker will properly run your task!

Known Issues:
1. Message acknowledgement does not work
2. amqp:// only no amqps:// implemented or tested
3. A few small TODOs left in there
4. No tests
 2014-02-11 16:35:43 -05:00
Ask Solem 3cb79f9c8c Fixes .travis.yml 2014-02-09 20:39:22 +00:00
Ask Solem 88913bf440 Sets release date 2014-02-09 15:47:36 +00:00
Ask Solem 60a5c63cb6 Support for coveralls 2014-02-09 15:47:11 +00:00
Ask Solem 6a4d729984 Bumps version to 3.0.12 and updates Changelog 2014-02-09 15:22:09 +00:00
Ask Solem Hoel f61144b6eb Merge pull request #309 from Bystroushaak/master 
Added link to the ZeroMQ website.
 2014-02-09 15:08:19 +00:00
Ask Solem a57852ea75 Py3.4: logging._levelNames was removed. Closes #311 2014-02-09 15:07:13 +00:00
Ask Solem f1abcb1b2e Adds Sam Stavinoha to AUTHORS 2014-02-09 15:03:33 +00:00
Sam Stavinoha b112f21798 raise Empty() rather than returning null message 2014-02-09 15:03:10 +00:00
Ask Solem d11ce77521 Merge branch 'master' of github.com:celery/kombu 2014-02-09 15:01:08 +00:00
Ask Solem Hoel 40ba050614 Merge pull request #314 from celery/fix-celery-1847 
Don't read from the socket more than requested. This prevents stalling i...
 2014-02-09 15:00:46 +00:00
Ionel Cristian Mărieș af3791ea94 Don't read from the socket more than requested. This prevents stalling issues (fixes celery/celery#1847). 2014-02-08 18:28:42 +02:00
Ask Solem 886db1e9cc Hub: move debug helpers into separate module 2014-02-06 00:17:15 +00:00
Bystroushaak 75451c75fd Added link to the ZeroMQ website. 2014-02-05 10:49:22 +01:00
Ask Solem 6a3e055268 Fixes typo 2014-02-03 17:03:28 +00:00
Ask Solem 3a2c0e0500 whitespace fix 2014-02-03 16:55:23 +00:00
Ask Solem 875375269d Bumps version to 3.0.11 2014-02-03 16:54:20 +00:00
Ask Solem 762adb61bd Updates Changelog 2014-02-03 16:47:06 +00:00
Ask Solem 5571c9ce22 SQS: Tests passing 2014-02-03 16:34:38 +00:00
Ask Solem c3ed134d92 Now depends on amqp 1.4.2 2014-02-03 16:29:55 +00:00
Ask Solem 83cc99eca4 Always trust application/data+application/text and no content_type. Closes #306 2014-02-03 16:26:14 +00:00
Ask Solem 7b48307674 Use uuid4() instead of uuid.getnode. celery/celery#1822 2014-02-03 15:48:18 +00:00
Ask Solem ded9a2b707 Merge branch 'master' of github.com:celery/kombu 2014-02-03 15:41:02 +00:00
Ask Solem f87256ed8e Adds async_consume example 2014-02-03 15:40:40 +00:00
Ionel Cristian Mărieș d87e335851 Merge pull request #308 from ionelmc/patch-1785 
Normalize fd in Hub.add
 2014-02-01 03:47:34 -08:00
Ionel Cristian Mărieș b0490a4899 Normalize fd in Hub.add 2014-01-31 11:06:18 +02:00
Ask Solem 4bb7cae805 Second try :sad: 2014-01-29 15:23:30 +00:00
Ask Solem 4ffa52125c Fixes SyntaxError 2014-01-29 14:45:16 +00:00
Ask Solem 66aee53095 Forgot to commit file (celery/celery#1818) 2014-01-28 16:23:50 +00:00
Ask Solem 8dfc24453c SQS: batch mode always consumes messages. Closes celery/celery#1818 2014-01-28 16:22:57 +00:00
Ask Solem 24e7e34782 Tests passing 2014-01-28 16:00:24 +00:00
Ask Solem f2e0635493 uuid.getnode() is already cached 2014-01-28 15:55:03 +00:00
Ask Solem a474b428c1 _receive_callback must also raise message.errors 2014-01-28 15:09:45 +00:00
Ask Solem c53e014e95 Tests passing on py3 2014-01-28 14:32:32 +00:00
Ask Solem d054ffc771 Tests passing 2014-01-28 13:54:04 +00:00
Ask Solem 4195662901 Message: Handle decompression and postencod errors as decode errors 2014-01-28 13:53:05 +00:00
Ask Solem 2cac6d09e1 Updates __all__ for .exceptions 2014-01-28 13:38:39 +00:00
Ask Solem 9f948a51e1 Adds Connection.get_heartbeat_interval() for access to the negotiated heartbeat value. 2014-01-28 13:17:04 +00:00
Ask Solem 2675518a2f flakes 2014-01-17 17:40:20 +00:00
Ask Solem d3eb931764 Bumps version to 3.0.10 and updates Changelog 2014-01-17 16:49:30 +00:00
Ask Solem d1ed0c27ff Now depends on amqp 1.4.1 2014-01-17 16:48:12 +00:00
Ask Solem 4eff9d82ad amqplib transport fix 2014-01-16 19:08:22 +00:00
Ask Solem b7f5f073c1 retry_over_time did not sleep as documented. Closes #303 2014-01-16 17:34:55 +00:00
Ask Solem 8e3798f1b3 Hub: Do not attempt to call unregister on closed poller 2014-01-16 16:19:39 +00:00
Ask Solem 5c9dcf54a1 Fixes for 7f84c4dd51 2014-01-16 16:08:58 +00:00
Ask Solem fdf5495bcf Tests passing 2014-01-16 15:44:12 +00:00
Ask Solem 5e54d1cb90 Timer: Must not use hash(entry) to order entries. Closes celery/celery#1798 2014-01-16 15:34:35 +00:00
Ask Solem bfcc6570b8 maybe_declare mus raise recoverable conncetion error, and not channel error 2014-01-16 14:57:24 +00:00
Ask Solem 7f84c4dd51 Redis: Make sure basic_cancel is not called while reading from socket. Closes celery/celery#1773 2014-01-14 14:22:12 +00:00
Ask Solem 26bf9faccb flakes 2014-01-13 17:57:42 +00:00