Skip to content

Commit 6935aa9

Browse files
committed
fixes subscription topic parsing
1 parent d24bbd5 commit 6935aa9

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

Adafruit_IO/mqtt_client.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,10 +85,10 @@ def _mqtt_disconnect(self, client, userdata, rc):
8585
def _mqtt_message(self, client, userdata, msg):
8686
logger.debug('Client on_message called.')
8787
# Parse out the feed id and call on_message callback.
88-
# Assumes topic looks like "api/feeds/{feed}/data/receive.json"
89-
if self.on_message is not None and msg.topic.startswith('api/feeds/') \
90-
and len(msg.topic) >= 28:
91-
feed = msg.topic[10:-18]
88+
# Assumes topic looks like "username/feeds/id"
89+
parsed_topic = msg.topic.split('/')
90+
if self.on_message is not None and self._username == parsed_topic[0]:
91+
feed = parsed_topic[2]
9292
payload = '' if msg.payload is None else msg.payload.decode('utf-8')
9393
self.on_message(self, feed, payload)
9494

0 commit comments

Comments
 (0)