Commit e677d636 authored by Jiahang Chen's avatar Jiahang Chen
Browse files

add channel confirmation

parent c4a4ee0d
Pipeline #385794 passed with stages
in 1 minute and 14 seconds
......@@ -450,6 +450,7 @@ def __on_broker_callback(self, ch, method, properties, body):
elif isinstance(body, str):
return
ch.basic_ack(method.delivery_tag)
message_type = body.get("messageType")
if message_type == "userMessage":
self.on_user_message(body)
......
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