diff --git a/adafruit_minimqtt/adafruit_minimqtt.py b/adafruit_minimqtt/adafruit_minimqtt.py index 41e01605..dac095cd 100644 --- a/adafruit_minimqtt/adafruit_minimqtt.py +++ b/adafruit_minimqtt/adafruit_minimqtt.py @@ -885,6 +885,9 @@ def subscribe(self, topic: str, qos: int = 0) -> None: self._subscribed_topics.append(t) return + if op == MQTT_PUBLISH: + continue + raise MMQTTException( f"invalid message received as response to SUBSCRIBE: {hex(op)}" )