Source code for pynenc_rabbitmq.util.rabbitmq_queue

from dataclasses import dataclass
from typing import Any



[docs]
@dataclass
class QueueSpec:
    """Specification for creating a RabbitMq queue."""

    name: str
    durable: bool = True
    exclusive: bool = False
    auto_delete: bool = False
    arguments: dict[str, Any] | None = None
    exchange: str = ""  # Empty string means default exchange
    routing_key: str | None = None  # If None, use queue name


[docs]
    def __post_init__(self) -> None:
        """Set routing_key to queue name if not specified."""
        if self.routing_key is None:
            self.routing_key = self.name