code: def consume(self, payload=True):
          
          with self.create_consumer() as consumer:
              for msg in consumer.iterqueue():
                  yield msg.payload if payload else msg
docs: Consume events.