def consume(self, event_type, no_ack=True, payload=True):
assert event_type in self.events<EOL>return current_queues.queues['<STR_LIT>'.format(event_type)].consume(<EOL>payload=payload)<EOL>
Comsume all pending events.