Commit f854545c authored by Nane Kratzke's avatar Nane Kratzke
Browse files

Handling message checks

parent 800cc74f
......@@ -44,10 +44,12 @@ class MQueue:
ts = time.time_ns()
since, data = entry
latency = (ts - int(data[b'timestamp'].decode('utf8'))) / 1000 / 1000
if b'data' in data:
message = json.loads(data[b'data'].decode('utf8'))
print(f"{latency:.2f}ms | msg { since }: { message }")
yield (since, message)
else:
print(f"Could not find payload data in msg { data }")
# Group listen for queueing communication patterns on message queues
#
......
Markdown is supported
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