'Start task consumer.'

def start(self, c):

    c.update_strategies()
    qos_global = (not c.connection.qos_semantics_matches_spec)
    c.connection.default_channel.basic_qos(0, c.initial_prefetch_count, qos_global)
    c.task_consumer = c.app.amqp.TaskConsumer(c.connection, on_decode_error=c.on_decode_error)
    def set_prefetch_count(prefetch_count):
        return c.task_consumer.qos(prefetch_count=prefetch_count, apply_global=qos_global)
    c.qos = QoS(set_prefetch_count, c.initial_prefetch_count)
