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

1212 Commits

Author SHA1 Message Date
Ask Solem 1da6be4a88 Merges changelog from 2.4. branch 2012-11-05 15:29:42 +00:00
Ask Solem 9140a4e1a3 Ensure/Autoretry no longer disconnects on channel_errors, and adds StdConnectionError 2012-11-05 14:06:20 +00:00
Ask Solem 2afe3fb996 Tests passing 2012-11-05 13:28:35 +00:00
Ask Solem aa0323e398 py-amqp replaces amqplib as the default transport 2012-11-05 13:27:07 +00:00
Ask Solem 02262aab38 Don't use LogMixin. Closes #169 2012-11-02 14:34:46 +00:00
Ask Solem 5deb7b8240 Adds Kevin McCarthy to AUTHORS 2012-11-02 14:18:43 +00:00
Kevin McCarthy 10319aa7e1 Make Queue Cycling in Redis More Fair 
The previous method of cycling queues with the Redis transport was
not fair if there were a lot of empty queues.  Queues waiting behind
lots of empty queues and at least one very full queue will be forced
to wait until the queue in front of it is rotated, and then will
only get the chance to be consumed once.  This changes the behavior
to rotate the most recently used queue to the back of the list,
elmininating the problem.  Closes #166
 2012-11-02 14:18:13 +00:00
Ask Solem 734317ce68 LamportClock.adjust now returns the new value 2012-11-02 14:14:29 +00:00
Ask Solem bee8c60af9 Fixes Py2.5 compat 2012-10-31 13:29:45 +00:00
Ask Solem 4318c50dd5 Merge branch 'master' of github.com:celery/kombu 
Conflicts:
	kombu/connection.py
 2012-10-31 13:17:21 +00:00
Ask Solem ddd8695d36 Fixes bug with float(heartbeat) 2012-10-31 13:15:57 +00:00
Mher Movsisyan 05362ada9a Merge branch 'master' of github.com:celery/kombu 2012-10-31 16:09:21 +04:00
Mher Movsisyan 150a99d83b Fixes heartbeat handling 2012-10-31 16:08:39 +04:00
Ask Solem 78b860b877 Merge branch 'master' of github.com:celery/kombu 2012-10-31 11:24:30 +00:00
Ask Solem 310492dc63 Adds LamportClock.sort_heap and LamportClock.sort 2012-10-31 11:23:49 +00:00
Mher Movsisyan 38cab0219f Fixes connection with heartbeat #170 2012-10-31 15:19:43 +04:00
Ask Solem 333dfa3cd0 [pidbox] Now uses a logical clock, and expires replies received after the timeout 2012-10-24 15:35:26 +01:00
Ask Solem 28c43e128d Tests passing 2012-10-24 14:51:06 +01:00
Ask Solem 0b26718b23 [pidbox] Now uses one queue per client instead of one per request 2012-10-24 14:04:30 +01:00
Ask Solem c6dab93755 Adds kombu.common oid_from(instance) 2012-10-24 12:02:30 +01:00
Ask Solem 9c190595f9 Refs to kombu top level symbols now resolve, and there's a kombu reference page 2012-10-23 16:24:39 +01:00
Ask Solem de46ac4081 Bumps version to 2.5.0rc1 and updates Changelog 2012-10-23 15:38:42 +01:00
Ask Solem 0cb5a85f0e Hack for static analyzers 2012-10-23 15:34:39 +01:00
Ask Solem 797f2456aa Adds Jasper Bryant-Greene to AUTHORS 2012-10-23 11:44:27 +01:00
Jasper Bryant-Greene f197c5bef3 MsgPack defaults to utf-8 encoding on packing, but no decoding on 
unpacking. On Python 3 this leads to unpacked messages having bytes
instances where str instances are expected, which leads to Celery being
unable to run any tasks as the names never compare as True. This patch
passes the encoding='utf-8' parameter to unpackb which leads to the
expected behaviour.

Closes #162
 2012-10-23 11:44:18 +01:00
Ask Solem ed9c776b7e Updates Changelog 2012-10-23 11:42:21 +01:00
Ask Solem 26cb844d83 [redis] Default for unacked_mutex_expire is now 5 minutes 2012-10-23 11:42:13 +01:00
Ask Solem 1188bf44ce [redis] Make restore limit configurable and make the default unlimited. Closes #164 2012-10-15 14:34:24 +01:00
Ask Solem ce467444b2 [redis] Use a mutex when restoring unacked messages 2012-10-15 14:27:38 +01:00
Ask Solem 93014554b5 Fixes Redis tests when redis not installed 2012-10-12 16:41:08 +01:00
Ask Solem 96b3b0b436 Merge branch 'master' of github.com:celery/kombu 2012-10-12 16:12:48 +01:00
Ask Solem 7b5551f179 Fixes typo in simple_task_queue example 2012-10-12 15:34:28 +01:00
Mher Movsisyan 9d0668e7fa Fixes non-blocking ssl in amqplib 2012-10-11 19:32:17 +04:00
Ask Solem 557f0da06d Updates Changelog 2012-10-10 13:25:14 +01:00
Ask Solem 3cbc9bb455 Tests passing 2012-10-04 16:37:34 +01:00
Ask Solem a76554684f [redis] Use common pool and disconnect pool on connection lost 2012-10-04 16:20:41 +01:00
Ask Solem d4b0c455d2 Updates Changelog 2012-10-04 16:18:43 +01:00
Ask Solem 1186cf82b4 Tests passing 2012-10-03 12:10:12 +01:00
Ask Solem 9cd9ed7274 Consumer can now work with raw messages using a new on_message callback 2012-10-03 11:26:54 +01:00
Ask Solem 00b795b980 Adds utils.compat.WhateverIO 2012-10-02 16:22:48 +01:00
Ask Solem 1fa78b0b1d Adds .common.ignore_errors 2012-10-02 16:22:33 +01:00
Ask Solem 14bd3bef6c Can now register serializers using setuptools entrypoints 2012-09-25 12:21:08 +01:00
Ask Solem ea28a118ba Adds kombu.common.QoS 2012-09-25 11:45:51 +01:00
Ask Solem 6efd615289 Updates Changelog 2012-09-21 14:28:42 +01:00
Ask Solem 0724575424 Adds 'from kombu import binding' 2012-09-21 14:21:33 +01:00
Ask Solem 30757ac944 Adds Rumyana Neykova to AUTHORS 2012-09-21 14:21:10 +01:00
Ask Solem 9960aed306 examples/ cosmetics 2012-09-21 14:18:37 +01:00
Ask Solem f678dc46ff Refactors multi-binding 2012-09-21 14:13:51 +01:00
Ask Solem e154619af4 flakes 2012-09-21 12:22:31 +01:00
Ask Solem 14f9563b1e Merge branch 'master' into rumineykova/master 2012-09-21 11:45:16 +01:00