Skip to content

ChannelBinding

faststream.specification.asyncapi.v2_6_0.schema.bindings.nats.channel.ChannelBinding #

Bases: BaseModel

A class to represent channel binding.

ATTRIBUTE DESCRIPTION
subject

subject of the channel binding
queue

optional queue for the channel binding
bindingVersion

version of the channel binding, default is "custom"

subject instance-attribute #

subject

queue class-attribute instance-attribute #

queue = None

bindingVersion class-attribute instance-attribute #

bindingVersion = 'custom'

from_sub classmethod #

from_sub(binding)
Source code in faststream/specification/asyncapi/v2_6_0/schema/bindings/nats/channel.py 
25
26
27
28
29
30
31
32
33
34
@classmethod
def from_sub(cls, binding: nats.ChannelBinding | None) -> Self | None:
    if binding is None:
        return None

    return cls(
        subject=binding.subject,
        queue=binding.queue,
        bindingVersion="custom",
    )

from_pub classmethod #

from_pub(binding)
Source code in faststream/specification/asyncapi/v2_6_0/schema/bindings/nats/channel.py 
36
37
38
39
40
41
42
43
44
45
@classmethod
def from_pub(cls, binding: nats.ChannelBinding | None) -> Self | None:
    if binding is None:
        return None

    return cls(
        subject=binding.subject,
        queue=binding.queue,
        bindingVersion="custom",
    )