6
6
from adafruit_esp32spi import adafruit_esp32spi_wifimanager
7
7
import adafruit_esp32spi .adafruit_esp32spi_socket as socket
8
8
9
- from adafruit_minimqtt import MQTT
9
+ import adafruit_minimqtt as MQTT
10
10
from adafruit_gc_iot_core import Cloud_Core , MQTT_API
11
11
12
12
### WiFi ###
@@ -92,6 +92,9 @@ def message(client, topic, msg):
92
92
wifi .connect ()
93
93
print ("Connected!" )
94
94
95
+ # Initialize MQTT interface with the esp interface
96
+ MQTT .set_socket (socket , esp )
97
+
95
98
# Initialize Google Cloud IoT Core interface
96
99
google_iot = Cloud_Core (esp , secrets )
97
100
@@ -101,14 +104,10 @@ def message(client, topic, msg):
101
104
# print("Your JWT is: ", jwt)
102
105
103
106
# Set up a new MiniMQTT Client
104
- client = MQTT (
105
- socket ,
106
- broker = google_iot .broker ,
107
- username = google_iot .username ,
108
- password = secrets ["jwt" ],
109
- client_id = google_iot .cid ,
110
- network_manager = wifi ,
111
- )
107
+ client = MQTT .MQTT (broker = google_iot .broker ,
108
+ username = google_iot .username ,
109
+ password = secrets ["jwt" ],
110
+ client_id = google_iot .cid )
112
111
113
112
# Initialize Google MQTT API Client
114
113
google_mqtt = MQTT_API (client )
0 commit comments