Method get_consumers

tools/queue_consumer.py:39–44

(self, Consumer, channel)

        self.queue = queue

    def get_consumers(self, Consumer, channel):
        return [
            Consumer(
                queues=[self.queue], accept=["pickle"], callbacks=[self.process_task]
            )
        ]

    def process_task(self, body, message):
        print("===================================================")