We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aaf2e53 commit cad708aCopy full SHA for cad708a
swpt_stomp/rmq.py
@@ -305,7 +305,7 @@ async def _publish_to_exchange(
305
exchange_name: str,
306
preprocess_message: Callable[[Message], Awaitable[RmqMessage]],
307
confirmation_timeout: float,
308
- is_peer_deactivated: Callable[[], Awaitable[bool]] = _NEVER,
+ is_peer_deactivated: Callable[[], Awaitable[bool]],
309
) -> None:
310
exchange = await channel.get_exchange(exchange_name, ensure=False)
311
deliveries: deque[_Delivery] = deque()
0 commit comments