def METHOD_NAME(self, Consumer, channel):
    return [Consumer(queues=celery_log_queue,
                     accept=['pickle', 'json'],
                     callbacks=[self.process_task])
            ]