Commit 463d4b48 authored by Daniela Rabe's avatar Daniela Rabe
Browse files

cleaned up

parent c5c30da6
......@@ -14,7 +14,7 @@ class MyMessageHandler:
PulsarConfigKeys.PERSISTENT: 'non-persistent',
PulsarConfigKeys.TENANT: 'public',
PulsarConfigKeys.NAMESPACE: 'default',
PulsarConfigKeys.TOPIC: 'synopsis',
PulsarConfigKeys.TOPIC: 'test-topic',
}
def __init__(self):
......
......@@ -76,7 +76,6 @@ class PulsarMessageHandler:
for producer in self.producers.values():
producer.close()
def wait_for_request(self):
# register request event handler
print('waiting for incoming request')
......@@ -89,7 +88,6 @@ class PulsarMessageHandler:
self.loop.close()
self.disconnect()
def receive_request(self):
try:
msg = json.loads(self.subscription.recv())
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment