Method consume

osquery/consumer.py:11–22

(self)

        self.consumer = self.client.subscribe(topic, consumer)

    def consume(self):
        waitingForMsg = True
        while waitingForMsg:
            try:
                msg = self.consumer.receive(2000)
                print("Received message '{}' id='{}'".format(msg.data(), msg.message_id()))
                self.consumer.acknowledge(msg)

                # waitingForMsg = False
            except:
                time.sleep(1)
                continue

    
    def __del__(self):