Skip to content

Commit

Permalink
fix: RabbitBroker's ping is more objective
Browse files Browse the repository at this point in the history
  • Loading branch information
roma-frolov committed Nov 21, 2024
1 parent f751238 commit eb4bbd2
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion faststream/rabbit/broker/broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -839,7 +839,7 @@ async def ping(self, timeout: Optional[float]) -> bool:
if cancel_scope.cancel_called:
return False

if not self._connection.is_closed:
if self._connection.connected.is_set():
return True

await anyio.sleep(sleep_time)
Expand Down

0 comments on commit eb4bbd2

Please sign in to comment.