diff --git a/adafruit_io/adafruit_io.py b/adafruit_io/adafruit_io.py index 53efb66..624753f 100755 --- a/adafruit_io/adafruit_io.py +++ b/adafruit_io/adafruit_io.py @@ -22,6 +22,7 @@ import json import re +from adafruit_minimqtt.adafruit_minimqtt import MMQTTException from adafruit_io.adafruit_io_errors import ( AdafruitIO_RequestError, AdafruitIO_ThrottleError, @@ -117,7 +118,10 @@ def disconnect(self): @property def is_connected(self): """Returns if connected to Adafruit IO MQTT Broker.""" - return self._client.is_connected + try: + return self._client.is_connected() + except MMQTTException: + return False # pylint: disable=not-callable, unused-argument def _on_connect_mqtt(self, client, userdata, flags, return_code): diff --git a/requirements.txt b/requirements.txt index f772f7b..ea5a0fd 100644 --- a/requirements.txt +++ b/requirements.txt @@ -4,3 +4,4 @@ Adafruit-Blinka Adafruit_CircuitPython_ESP32SPI +Adafruit_CircuitPython_MiniMQTT