From 9f1c3d04c7f37c51a1cbff1f2c75552054b18377 Mon Sep 17 00:00:00 2001
From: Andrew Mirsky <andrew@mirsky.net>
Date: Wed, 2 Jul 2025 16:24:57 -0400
Subject: [PATCH] even though only certain not connected sessions need to
 retain messages, none of the non connected sessions need to receive a
 broadcast message

---
 amqtt/broker.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/amqtt/broker.py b/amqtt/broker.py
index 1d86507..3a026c9 100644
--- a/amqtt/broker.py
+++ b/amqtt/broker.py
@@ -901,6 +901,10 @@ class Broker:
                     await self._retain_broadcast_message(broadcast, qos, target_session)
                     continue
 
+                # Only broadcast the message to connected clients
+                if target_session.transitions.state != "connected":
+                    continue
+
                 self.logger.debug(
                     f"Broadcasting message from {format_client_message(session=broadcast['session'])}"
                     f" on topic '{broadcast['topic']}' to {format_client_message(session=target_session)}",