Commit 953ba046 authored by Schultz, Lucian's avatar Schultz, Lucian
Browse files

commit to trigger

parent 87f734c7
Pipeline #41184 passed with stages
in 53 seconds
......@@ -10,6 +10,7 @@ r = redis.Redis(host=host, port=port, db=0)
ch = r.pubsub()
ch.subscribe(channel)
#listening
for msg in ch.listen():
try:
r = time.time_ns()
......@@ -18,4 +19,3 @@ for msg in ch.listen():
print(f"{latency:.2f}ms | msg: { json.dumps(data) }")
except Exception as ex:
print(f"Could not process message '{ msg }' caused by { ex }")
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