Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Set _in_poll before sending the BRPOP command instead of after. 

This removes a race condition where _avail_client can return a polling client instead of a new client.

Fixes issue #171
This commit is contained in:
Ollie Walsh 2012-11-14 12:29:00 +00:00 committed by Ask Solem
parent f6075b20f8
commit f21895ebd4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kombu/transport/redis.py
View File

@ -400,8 +400,8 @@ class Channel(virtual.Channel):
c = self.subclient
if c.connection._sock is None:
c.connection.connect()
self.subclient.subscribe(keys)
self._in_listen = True
self.subclient.subscribe(keys)
def _handle_message(self, client, r):
if r[0] == 'unsubscribe' and r[2] == 0:
@ -433,8 +433,8 @@ class Channel(virtual.Channel):
return
keys = [self._q_for_pri(queue, pri) for pri in PRIORITY_STEPS
for queue in queues] + [timeout or 0]
self.client.connection.send_command('BRPOP', *keys)
self._in_poll = True
self.client.connection.send_command('BRPOP', *keys)
def _brpop_read(self, **options):
try: