updating mqtt_client

Author: BlitzCityDIY

examples/esp32spi/minimqtt_pub_sub_blocking_esp32spi.py

@@ -87,7 +87,7 @@ def message(client, topic, message):
 
 # Set up a MiniMQTT Client
 mqtt_client = MQTT.MQTT(
-    broker=os.getenv("broker"), username=aio_username, password=aio_key
+    broker="io.adafruit.com", username=aio_username, password=aio_key
 )
 
 # Setup the callback methods above

examples/esp32spi/minimqtt_pub_sub_nonblocking_esp32spi.py

@@ -86,7 +86,7 @@ def message(client, topic, message):
 
 # Set up a MiniMQTT Client
 mqtt_client = MQTT.MQTT(
-    broker=os.getenv("broker"), username=aio_username, password=aio_key
+    broker="io.adafruit.com", username=aio_username, password=aio_key
 )
 
 # Setup the callback methods above

examples/minimqtt_simpletest.py

@@ -16,8 +16,6 @@
 # or if you need your Adafruit IO key.)
 aio_username = os.getenv("aio_username")
 aio_key = os.getenv("aio_key")
-aio_broker = os.getenv("broker")
-aio_port = os.getenv("port")
 
 print("Connecting to %s" % os.getenv("CIRCUITPY_WIFI_SSID"))
 wifi.radio.connect(
@@ -77,8 +75,8 @@ def message(client, topic, message):
 
 # Set up a MiniMQTT Client
 mqtt_client = MQTT.MQTT(
-    broker=aio_broker,
-    port=aio_port,
+    broker="io.adafruit.com",
+    port=8883,
     username=os.getenv("CIRCUITPY_WIFI_SSID"),
     password=os.getenv("CIRCUITPY_WIFI_PASSWORD"),
     socket_pool=pool,

examples/native_networking/minimqtt_adafruitio_native_networking.py

@@ -17,7 +17,6 @@
 # or if you need your Adafruit IO key.)
 aio_username = os.getenv("aio_username")
 aio_key = os.getenv("aio_key")
-aio_port = os.getenv("port")
 
 print("Connecting to %s" % os.getenv("CIRCUITPY_WIFI_SSID"))
 wifi.radio.connect(
@@ -62,9 +61,9 @@ def message(client, topic, message):
 # Set up a MiniMQTT Client
 mqtt_client = MQTT.MQTT(
     broker="io.adafruit.com",
-    port=aio_port,
-    username=aio_username,
-    password=aio_key,
+    port=8883,
+    username=os.getenv("CIRCUITPY_WIFI_SSID"),
+    password=os.getenv("CIRCUITPY_WIFI_PASSWORD"),
     socket_pool=pool,
     ssl_context=ssl.create_default_context(),
 )