NatsMessage(raw_message, body, headers=dict(), batch_headers=list(), path=dict(), content_type=None, reply_to='', message_id=gen_cor_id(), correlation_id=gen_cor_id())
Bases: StreamMessage[Msg]
A class to represent a NATS message.
instance-attribute
class-attribute instance-attribute
class-attribute instance-attribute
class-attribute instance-attribute
class-attribute instance-attribute
class-attribute instance-attribute
class-attribute instance-attribute
processed = field(default=False, init=False)
class-attribute instance-attribute
committed = field(default=None, init=False)
property writable
async
Serialize the message by lazy decoder.
Source code in faststream/broker/message.py
| async def decode(self) -> Optional["DecodedMessage"]:
"""Serialize the message by lazy decoder."""
# TODO: make it lazy after `decoded_body` removed
return self._decoded_body
|
async
Source code in faststream/nats/message.py
| async def ack(self) -> None:
# Check `self.raw_message._ackd` instead of `self.committed`
# to be compatible with `self.raw_message.ack()`
if not self.raw_message._ackd:
await self.raw_message.ack()
await super().ack()
|
async
Source code in faststream/nats/message.py
| async def nack(
self,
delay: Union[int, float, None] = None,
) -> None:
if not self.raw_message._ackd:
await self.raw_message.nak(delay=delay)
await super().nack()
|
async
Source code in faststream/nats/message.py
| async def reject(self) -> None:
if not self.raw_message._ackd:
await self.raw_message.term()
await super().reject()
|
async
Source code in faststream/nats/message.py
| async def in_progress(self) -> None:
if not self.raw_message._ackd:
await self.raw_message.in_progress()
|