@@ -29,6 +29,7 @@ def asynloop(obj, connection, consumer, blueprint, hub, qos,
readers, writers = hub.readers, hub.writers
hbtick = connection.heartbeat_check
errors = connection.connection_errors
+ heartbeat = connection.connection.heartbeat # negotiated
hub_add, hub_remove = hub.add, hub.remove
on_task_received = obj.create_task_handler()
Ask Solem