merging

Revert "merging"

This reverts commit 4f3aea6b2cfaa98be31d82e5076fe3df29d198f7.

Revert "Revert "merging""

This reverts commit a250e00d6964442592fad5fbeb7f31ddb339daf7.

Delete mpy.sh

Author: Jim Bennett

adafruit_azureiot/iot_mqtt.py

@@ -213,7 +213,7 @@ def _handle_device_twin_update(self, msg: str, topic: str) -> None:
         for property_name, value in desired.items():
             self._callback.device_twin_desired_updated(property_name, value, desired_version)
 
-    def _handle_direct_method(self, msg: str, topic: str) -> None:
+    def _handle_direct_method(self, client, topic: str, msg: str) -> None:
         index = topic.find("$rid=")
         method_id = 1
         method_name = "None"
@@ -278,7 +278,8 @@ def _on_message(self, client, msg_topic, payload) -> None:
             if topic.startswith("$iothub/twin/PATCH/properties/desired/") or topic.startswith("$iothub/twin/res/200/?$rid="):
                 self._handle_device_twin_update(str(msg), topic)
             elif topic.startswith("$iothub/methods"):
-                self._handle_direct_method(str(msg), topic)
+                pass
+                # self._handle_direct_method(str(msg), topic)
             else:
                 if not topic.startswith("$iothub/twin/res/"):  # not twin response
                     self._logger.error("ERROR: unknown twin! - {}".format(msg))
@@ -365,7 +366,9 @@ def __init__(
     def _subscribe_to_core_topics(self):
         self._mqtts.subscribe("devices/{}/messages/events/#".format(self._device_id))
         self._mqtts.subscribe("devices/{}/messages/devicebound/#".format(self._device_id))
-        self._mqtts.subscribe("$iothub/methods/#")
+
+        self._mqtts.add_topic_callback("$iothub/methods/#", self._handle_direct_method)
+        # self._mqtts.subscribe("$iothub/methods/#")
 
     def _subscribe_to_twin_topics(self):
         self._mqtts.subscribe("$iothub/twin/PATCH/properties/desired/#")  # twin desired property changes