'Shutdown task consumer.'

def shutdown(self, c):

    if c.task_consumer:
        self.stop(c)
        debug(u'Closing    consumer    channel...')
        ignore_errors(c, c.task_consumer.close)
        c.task_consumer = None
