Please sign in to comment.
|@@ -44,10 +44,10 @@ def asynloop(obj, connection, consumer, blueprint, hub, qos,|
|_enable_amqheartbeats(hub.timer, connection, rate=hbrate)|
|consumer.on_message = on_task_received|
|# did_start_ok will verify that pool processes were able to start,|
|# but this will only work the first time we start, as|