Skip to content

Commit 7401518

Browse files
committed
Update connection check to use is_alive method in StompBroker
1 parent 8c8f74c commit 7401518

File tree

1 file changed

+1
-1
lines changed
  • packages/faststream-stomp/faststream_stomp

1 file changed

+1
-1
lines changed

packages/faststream-stomp/faststream_stomp/broker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ async def ping(self, timeout: float | None = None) -> bool:
114114
if cancel_scope.cancel_called:
115115
return False
116116

117-
if self._connection._connection_manager._active_connection_state: # noqa: SLF001
117+
if self._connection.is_alive():
118118
return True
119119

120120
await anyio.sleep(sleep_time) # pragma: no cover

0 commit comments

Comments
 (0)