Call `heartbeat_check` in `ConsumerMixin`

This also adjusts the docs to be a little less specific about the rate
argument and a little more specific about how often the function should
be called.

1 files changed, 1 insertions, 0 deletions

diff --git a/kombu/mixins.py b/kombu/mixins.py
index 4db6a22b..8d962d05 100644
--- a/kombu/mixins.py
+++ b/kombu/mixins.py
@@ -188,6 +188,7 @@ class ConsumerMixin(object):
             for i in limit and range(limit) or count():
                 if self.should_stop:
                     break
+                conn.heartbeat_check()
                 self.on_iteration()
                 try:
                     conn.drain_events(timeout=safety_interval)