Skip to content

Queue

faststream.specification.asyncapi.v2_6_0.schema.bindings.amqp.channel.Queue #

Bases: BaseModel

A class to represent a queue.

name instance-attribute #

name: str

durable instance-attribute #

durable: bool

exclusive instance-attribute #

exclusive: bool

autoDelete instance-attribute #

autoDelete: bool

vhost class-attribute instance-attribute #

vhost: str = '/'

from_spec classmethod #

from_spec(binding: None, vhost: str) -> None

from_spec(binding: Queue, vhost: str) -> Self

from_spec(binding: Queue | None, vhost: str) -> Self | None
Source code in faststream/specification/asyncapi/v2_6_0/schema/bindings/amqp/channel.py 
39
40
41
42
43
44
45
46
47
48
49
50
@classmethod
def from_spec(cls, binding: amqp.Queue | None, vhost: str) -> Self | None:
    if binding is None:
        return None

    return cls(
        name=binding.name,
        durable=binding.durable,
        exclusive=binding.exclusive,
        autoDelete=binding.auto_delete,
        vhost=vhost,
    )