Skip to content

EndlessWatcher

faststream.broker.acknowledgement_watcher.EndlessWatcher #

EndlessWatcher(max_tries=0, logger=None)

Bases: BaseWatcher

A class to watch and track messages.

Source code in faststream/broker/acknowledgement_watcher.py 
28
29
30
31
32
33
34
def __init__(
    self,
    max_tries: int = 0,
    logger: Optional["LoggerProto"] = None,
) -> None:
    self.logger = logger
    self.max_tries = max_tries

max_tries instance-attribute #

max_tries = max_tries

logger instance-attribute #

logger = logger

add #

add(message_id)

Add a message to the list.

Source code in faststream/broker/acknowledgement_watcher.py 
55
56
57
def add(self, message_id: str) -> None:
    """Add a message to the list."""
    pass

is_max #

is_max(message_id)

Check if the given message ID is the maximum attempt.

Source code in faststream/broker/acknowledgement_watcher.py 
59
60
61
def is_max(self, message_id: str) -> bool:
    """Check if the given message ID is the maximum attempt."""
    return False

remove #

remove(message_id)

Remove a message.

Source code in faststream/broker/acknowledgement_watcher.py 
63
64
65
def remove(self, message_id: str) -> None:
    """Remove a message."""
    pass