Use Client.check_server_alive_interval_factor (#110)

Author: vrslev

packages/stompman/stompman/client.py

@@ -175,4 +175,4 @@ async def subscribe_with_manual_ack(
     def is_alive(self) -> bool:
         return (
             self._connection_manager._active_connection_state or False  # noqa: SLF001
-        ) and self._connection_manager._active_connection_state.is_alive()  # noqa: SLF001
+        ) and self._connection_manager._active_connection_state.is_alive(self.check_server_alive_interval_factor)  # noqa: SLF001

packages/stompman/stompman/connection_manager.py

@@ -28,10 +28,13 @@ class ActiveConnectionState:
     lifespan: "AbstractConnectionLifespan"
     server_heartbeat: Heartbeat
 
-    def is_alive(self) -> bool:
+    def is_alive(self, check_server_alive_interval_factor: int) -> bool:
         if not (last_read_time := self.connection.last_read_time):
             return True
-        return (self.server_heartbeat.will_send_interval_ms / 1000) > (time.time() - last_read_time)
+
+        return (self.server_heartbeat.will_send_interval_ms / 1000 * check_server_alive_interval_factor) > (
+            time.time() - last_read_time
+        )
 
 
 @dataclass(kw_only=True, slots=True)
@@ -99,7 +102,7 @@ async def _check_server_heartbeat_forever(self, receive_heartbeat_interval_ms: i
             await asyncio.sleep(receive_heartbeat_interval_seconds * self.check_server_alive_interval_factor)
             if not self._active_connection_state:
                 continue
-            if not self._active_connection_state.is_alive():
+            if not self._active_connection_state.is_alive(self.check_server_alive_interval_factor):
                 self._active_connection_state = None
 
     async def _create_connection_to_one_server(

packages/stompman/test_stompman/test_aliveness.py

@@ -17,5 +17,5 @@ async def test_connection_alive(is_alive: bool) -> None:  # noqa: FBT001
     )
     client = await EnrichedClient(connection_class=connection_class).__aenter__()
     assert client._connection_manager._active_connection_state
-    client._connection_manager._active_connection_state.connection.last_read_time = time.time() - 1 + is_alive
+    client._connection_manager._active_connection_state.connection.last_read_time = time.time() if is_alive else 10
     assert client.is_alive() == is_alive