Skip to content

ChannelBinding

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

Bases: BaseModel

A class to represent channel binding.

subject instance-attribute #

subject: str

queue class-attribute instance-attribute #

queue: str | None = None

bindingVersion class-attribute instance-attribute #

bindingVersion: str = 'custom'

from_sub classmethod #

from_sub(binding: ChannelBinding | None) -> Self | None
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: ChannelBinding | None) -> Self | None
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",
    )