Skip to content

RabbitResponse

faststream.rabbit.RabbitResponse #

RabbitResponse(
    body: AioPikaSendableMessage,
    *,
    timeout: TimeoutType = None,
    mandatory: bool = True,
    immediate: bool = False,
    **message_options: Unpack[MessageOptions],
)

Bases: Response

Source code in faststream/rabbit/response.py 
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
def __init__(
    self,
    body: "AioPikaSendableMessage",
    *,
    timeout: "TimeoutType" = None,
    mandatory: bool = True,
    immediate: bool = False,
    **message_options: Unpack["MessageOptions"],
) -> None:
    headers = message_options.pop("headers", {})
    correlation_id = message_options.pop("correlation_id", None)

    super().__init__(
        body=body,
        headers=headers,
        correlation_id=correlation_id,
    )

    self.message_options: BasicMessageOptions = message_options
    self.publish_options: PublishOptions = {
        "mandatory": mandatory,
        "immediate": immediate,
        "timeout": timeout,
    }

body instance-attribute #

body = body

headers instance-attribute #

headers = headers or {}

correlation_id instance-attribute #

correlation_id = correlation_id

message_options instance-attribute #

message_options: BasicMessageOptions = message_options

publish_options instance-attribute #

publish_options: PublishOptions = {
    "mandatory": mandatory,
    "immediate": immediate,
    "timeout": timeout,
}

as_publish_command #

as_publish_command() -> RabbitPublishCommand
Source code in faststream/rabbit/response.py 
46
47
48
49
50
51
52
53
54
55
56
@override
def as_publish_command(self) -> "RabbitPublishCommand":
    return RabbitPublishCommand(
        message=self.body,
        headers=self.headers,
        correlation_id=self.correlation_id,
        _publish_type=PublishType.PUBLISH,
        routing_key="",
        **self.publish_options,
        **self.message_options,
    )