Skip to content

ReplyConfig

faststream.rabbit.schemas.reply.ReplyConfig #

ReplyConfig(mandatory=True, immediate=False, persist=False)

Class to store a config for subscribers' replies.

Source code in faststream/rabbit/schemas/reply.py 
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
def __init__(
    self,
    mandatory: Annotated[
        bool,
        Doc(
            "Client waits for confirmation that the message is placed to some queue. "
            "RabbitMQ returns message to client if there is no suitable queue."
        ),
    ] = True,
    immediate: Annotated[
        bool,
        Doc(
            "Client expects that there is consumer ready to take the message to work. "
            "RabbitMQ returns message to client if there is no suitable consumer."
        ),
    ] = False,
    persist: Annotated[
        bool,
        Doc("Restore the message on RabbitMQ reboot."),
    ] = False,
) -> None:
    self.mandatory = mandatory
    self.immediate = immediate
    self.persist = persist

mandatory instance-attribute #

mandatory = mandatory

immediate instance-attribute #

immediate = immediate

persist instance-attribute #

persist = persist

to_dict #

to_dict()

Convert object to options dict.

Source code in faststream/rabbit/schemas/reply.py 
40
41
42
43
44
45
46
def to_dict(self) -> Dict[str, bool]:
    """Convert object to options dict."""
    return {
        "mandatory": self.mandatory,
        "immediate": self.immediate,
        "persist": self.persist,
    }