From 95183865b7b90bda70e49bd7605bb721f6cf02ff Mon Sep 17 00:00:00 2001 From: Andrew Mirsky Date: Wed, 2 Jul 2025 13:25:31 -0400 Subject: [PATCH] use MQTT terminology --- amqtt/broker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/amqtt/broker.py b/amqtt/broker.py index 1231fbf..1d86507 100644 --- a/amqtt/broker.py +++ b/amqtt/broker.py @@ -499,10 +499,10 @@ class Broker: await handler.start() # publish messages that were retained because the client session was disconnected - self.logger.debug(f"Offline messages queue size: {client_session.retained_messages.qsize()}") + self.logger.debug(f"Retained messages queue size: {client_session.retained_messages.qsize()}") await self._publish_session_retained_messages(client_session) - # if this is not a new session, there are subscriptions associated with them + # if this is not a new session, there are subscriptions associated with them; publish any topic retained messages self.logger.debug("Publish retained messages to a pre-existing session's subscriptions.") for topic in self._subscriptions: await self._publish_retained_messages_for_subscription( (topic, QOS_0), client_session)