Method consume

t/unit/worker/test_control.py:385–386

(self)

                self.queues.append(queue.name)

            def consume(self):
                self.consuming = True

            def cancel_by_queue(self, queue):
                self.canceled.append(queue)