Skip to content

NatsMessage

faststream.nats.message.NatsMessage dataclass #

Bases: StreamMessage[Msg]

body instance-attribute #

body: Union[bytes, Any]

content_type class-attribute instance-attribute #

content_type: Optional[str] = None

correlation_id class-attribute instance-attribute #

correlation_id: str = field(
    default_factory=lambda: str(uuid4())
)

decoded_body class-attribute instance-attribute #

decoded_body: Optional[DecodedMessage] = None

headers class-attribute instance-attribute #

headers: AnyDict = field(default_factory=dict)

is_js class-attribute instance-attribute #

is_js: bool = True

message_id class-attribute instance-attribute #

message_id: str = field(
    default_factory=lambda: str(uuid4())
)

path class-attribute instance-attribute #

path: AnyDict = field(default_factory=dict)

processed class-attribute instance-attribute #

processed: bool = False

raw_message instance-attribute #

raw_message: Msg

reply_to class-attribute instance-attribute #

reply_to: str = ''

ack async #

ack(**kwargs: Any) -> None
Source code in faststream/nats/message.py 
13
14
15
async def ack(self, **kwargs: Any) -> None:
    if self.is_js and not self.raw_message._ackd:
        await self.raw_message.ack()

nack async #

nack(**kwargs: Any) -> None
Source code in faststream/nats/message.py 
17
18
19
async def nack(self, **kwargs: Any) -> None:
    if self.is_js and not self.raw_message._ackd:
        await self.raw_message.nak(**kwargs)

reject async #

reject(**kwargs: Any) -> None
Source code in faststream/nats/message.py 
21
22
23
async def reject(self, **kwargs: Any) -> None:
    if self.is_js and not self.raw_message._ackd:
        await self.raw_message.term()
Last update: 2023-11-13