Skip to content

Message

faststream.specification.asyncapi.v2_6_0.schema.message.Message #

Bases: BaseModel

A class to represent a message.

title class-attribute instance-attribute #

title: str | None = None

name class-attribute instance-attribute #

name: str | None = None

summary class-attribute instance-attribute #

summary: str | None = None

description class-attribute instance-attribute #

description: str | None = None

messageId class-attribute instance-attribute #

messageId: str | None = None

correlationId class-attribute instance-attribute #

correlationId: CorrelationId | None = None

contentType class-attribute instance-attribute #

contentType: str | None = None

payload instance-attribute #

payload: dict[str, Any]

tags class-attribute instance-attribute #

tags: list[Tag | dict[str, Any]] | None = None

model_config class-attribute instance-attribute #

model_config = {'extra': 'allow'}

Config #

extra class-attribute instance-attribute #

extra = 'allow'

from_spec classmethod #

from_spec(message: Message) -> Self
Source code in faststream/specification/asyncapi/v2_6_0/schema/message.py 
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
@classmethod
def from_spec(cls, message: SpecMessage) -> Self:
    return cls(
        title=message.title,
        payload=message.payload,
        correlationId=CorrelationId(
            description=None,
            location="$message.header#/correlation_id",
        ),
        name=None,
        summary=None,
        description=None,
        messageId=None,
        contentType=None,
        tags=None,
    )