diff --git a/ml/thing.py b/ml/thing.py index 4094af341eb47595c37f874b1bba4daa4cc55b79..8f971998353b3a4b754aa175d9cae84439b02bfb 100644 --- a/ml/thing.py +++ b/ml/thing.py @@ -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)