code: def consume(self, event_type, no_ack=True, payload=True):
          
          assert event_type in self.events
          return current_queues.queues['stats-{}'.format(event_type)].consume(
              payload=payload)
docs: Comsume all pending events.