'Get consumer for the queue this task is sent to.
Deprecated!
Should be replaced by :class:`@amqp.TaskConsumer`.'

@classmethod
def get_consumer(cls, connection=None, queues=None, **kwargs):

    Q = cls._get_app().amqp
    connection = (connection or cls.establish_connection())
    if (queues is None):
        queues = (Q.queues[cls.queue] if cls.queue else Q.default_queue)
    return Q.TaskConsumer(connection, queues, **kwargs)
