Message

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

Bases: BaseModel

A class to represent a message.

ATTRIBUTE	DESCRIPTION
title	title of the message
name	name of the message
summary	summary of the message
description	description of the message
messageId	ID of the message
correlationId	correlation ID of the message
contentType	content type of the message
payload	dictionary representing the payload of the message
tags	list of tags associated with the message

title class-attribute instance-attribute

title = None

name class-attribute instance-attribute

name = None

summary class-attribute instance-attribute

summary = None

description class-attribute instance-attribute

description = None

messageId class-attribute instance-attribute

messageId = None

correlationId class-attribute instance-attribute

correlationId = None

contentType class-attribute instance-attribute

contentType = None

payload instance-attribute

payload

tags class-attribute instance-attribute

tags = 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)

Source code in faststream/specification/asyncapi/v2_6_0/schema/message.py

@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,
    )