handle throttleerrors

Author: brentru

adafruit_io/adafruit_io.py

@@ -174,6 +174,8 @@ def _on_message_mqtt(self, client, topic, payload):
                     messages.append(payload)
                 topic_name = feeds
                 message = messages
+            elif topic_name[1] == "throttle":
+                raise AdafruitIO_ThrottleError(payload)
             elif topic_name[0] == "time":
                 # Adafruit IO Time Topic
                 topic_name = topic_name[1]

adafruit_io/adafruit_io_errors.py

@@ -28,13 +28,7 @@
 
 
 class AdafruitIO_ThrottleError(Exception):
-    """Adafruit IO request error class for rate-limiting"""
-
-    def __init__(self):
-        super().__init__(
-            "Number of Adafruit IO Requests exceeded! \
-                                                            Please try again in 30 seconds.."
-        )
+    """Adafruit IO request error class for rate-limiting."""
 
 
 class AdafruitIO_RequestError(Exception):