1 files changed, 4 insertions, 0 deletions
diff --git a/shared/src/shared/broker.py b/shared/src/shared/broker.py
index 9a50441..0f87b06 100644
--- a/shared/src/shared/broker.py
+++ b/shared/src/shared/broker.py
@@ -38,6 +38,10 @@ class RedisBroker:
                         messages.append(json.loads(payload))
         return messages
 
+    async def ping(self) -> bool:
+        """Ping the Redis server; return True if reachable."""
+        return await self._redis.ping()
+
     async def close(self) -> None:
         """Close the Redis connection."""
         await self._redis.aclose()