Skip to content

Commit 052b539

Browse files
authored
Merge pull request #25 from justmobilize/update-legacy-set-socket-examples
Update legacy set_socket examples
2 parents c343347 + 2de1fa6 commit 052b539

File tree

2 files changed

+18
-8
lines changed

2 files changed

+18
-8
lines changed

examples/aws_iot_shadows.py

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,10 @@
77
import busio
88
from digitalio import DigitalInOut
99
import neopixel
10+
import adafruit_connection_manager
1011
from adafruit_esp32spi import adafruit_esp32spi
1112
from adafruit_esp32spi import adafruit_esp32spi_wifimanager
12-
import adafruit_esp32spi.adafruit_esp32spi_socket as socket
13+
import adafruit_esp32spi.adafruit_esp32spi_socket as pool
1314
import adafruit_minimqtt.adafruit_minimqtt as MQTT
1415
from adafruit_aws_iot import MQTT_CLIENT
1516

@@ -134,11 +135,15 @@ def message(client, topic, msg):
134135
wifi.connect()
135136
print("Connected!")
136137

137-
# Initialize MQTT interface with the esp interface
138-
MQTT.set_socket(socket, esp)
138+
ssl_context = adafruit_connection_manager.create_fake_ssl_context(pool, esp)
139139

140140
# Set up a new MiniMQTT Client
141-
client = MQTT.MQTT(broker=secrets["broker"], client_id=secrets["client_id"])
141+
client = MQTT.MQTT(
142+
broker=secrets["broker"],
143+
client_id=secrets["client_id"],
144+
socket_pool=pool,
145+
ssl_context=ssl_context,
146+
)
142147

143148
# Initialize AWS IoT MQTT API Client
144149
aws_iot = MQTT_CLIENT(client)

examples/aws_iot_simpletest.py

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,10 @@
77
import busio
88
from digitalio import DigitalInOut
99
import neopixel
10+
import adafruit_connection_manager
1011
from adafruit_esp32spi import adafruit_esp32spi
1112
from adafruit_esp32spi import adafruit_esp32spi_wifimanager
12-
import adafruit_esp32spi.adafruit_esp32spi_socket as socket
13+
import adafruit_esp32spi.adafruit_esp32spi_socket as pool
1314
import adafruit_minimqtt.adafruit_minimqtt as MQTT
1415
from adafruit_aws_iot import MQTT_CLIENT
1516

@@ -131,11 +132,15 @@ def message(client, topic, msg):
131132
wifi.connect()
132133
print("Connected!")
133134

134-
# Initialize MQTT interface with the esp interface
135-
MQTT.set_socket(socket, esp)
135+
ssl_context = adafruit_connection_manager.create_fake_ssl_context(pool, esp)
136136

137137
# Set up a new MiniMQTT Client
138-
client = MQTT.MQTT(broker=secrets["broker"], client_id=secrets["client_id"])
138+
client = MQTT.MQTT(
139+
broker=secrets["broker"],
140+
client_id=secrets["client_id"],
141+
socket_pool=pool,
142+
ssl_context=ssl_context,
143+
)
139144

140145
# Initialize AWS IoT MQTT API Client
141146
aws_iot = MQTT_CLIENT(client)

0 commit comments

Comments
 (0)