Method __init__

osquery/consumer.py:7–9

(self, service_url, topic, token, consumer)

class Consumer:

    def __init__(self, service_url, topic, token, consumer):
        self.client = pulsar.Client(service_url, authentication=pulsar.AuthenticationToken(token))
        self.consumer = self.client.subscribe(topic, consumer)

    def consume(self):
        waitingForMsg = True