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

Merge branch 'djmitche/call-heartbeat'

This commit is contained in:
Ask Solem 2014-01-13 16:15:07 +00:00
parent 61816562d9 72a0644086
commit 11933461aa
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kombu/mixins.py
View File

@ -188,11 +188,11 @@ class ConsumerMixin(object):
for i in limit and range(limit) or count(): for i in limit and range(limit) or count():
if self.should_stop: if self.should_stop:
break break
conn.heartbeat_check()
self.on_iteration() self.on_iteration()
try: try:
conn.drain_events(timeout=safety_interval) conn.drain_events(timeout=safety_interval)
except socket.timeout: except socket.timeout:
conn.heartbeat_check()
elapsed += safety_interval elapsed += safety_interval
if timeout and elapsed >= timeout: if timeout and elapsed >= timeout:
raise raise