|
1 | 1 | # CircuitPython MiniMQTT Library |
2 | | -# Adafruit IO SSL/TLS Example for WiFi (ESP32SPI) |
| 2 | +# Adafruit IO SSL/TLS Example for WiFi |
3 | 3 | import board |
4 | 4 | import busio |
5 | 5 | from digitalio import DigitalInOut |
6 | 6 | import neopixel |
7 | 7 | from adafruit_esp32spi import adafruit_esp32spi |
8 | 8 | from adafruit_esp32spi import adafruit_esp32spi_wifimanager |
9 | 9 | import adafruit_esp32spi.adafruit_esp32spi_socket as socket |
10 | | -from adafruit_minimqtt import MQTT |
| 10 | +import adafruit_minimqtt as MQTT |
11 | 11 |
|
12 | 12 | ### WiFi ### |
13 | 13 |
|
@@ -72,21 +72,25 @@ def message(client, topic, message): |
72 | 72 | print('New message on topic {0}: {1}'.format(topic, message)) |
73 | 73 |
|
74 | 74 | # Connect to WiFi |
| 75 | +print("Connecting to WiFi...") |
75 | 76 | wifi.connect() |
| 77 | +print("Connected!") |
| 78 | + |
| 79 | +# Initialize MQTT interface with the esp interface |
| 80 | +MQTT.set_socket(socket, esp) |
76 | 81 |
|
77 | 82 | # Set up a MiniMQTT Client |
78 | | -mqtt_client = MQTT(socket, |
79 | | - broker = secrets['broker'], |
80 | | - username = secrets['user'], |
81 | | - password = secrets['pass'], |
82 | | - network_manager = wifi) |
| 83 | +mqtt_client = MQTT.MQTT(broker = secrets['broker'], |
| 84 | + username = secrets['user'], |
| 85 | + password = secrets['pass']) |
83 | 86 |
|
84 | 87 | # Setup the callback methods above |
85 | 88 | mqtt_client.on_connect = connected |
86 | 89 | mqtt_client.on_disconnect = disconnected |
87 | 90 | mqtt_client.on_message = message |
88 | 91 |
|
89 | 92 | # Connect the client to the MQTT broker. |
| 93 | +print('Connecting to MQTT broker...') |
90 | 94 | mqtt_client.connect() |
91 | 95 |
|
92 | 96 | # Start a blocking message loop |
|
0 commit comments