Method declare_queue

dramatiq/broker.py:225–232

Declare a queue on this broker. This method must be idempotent. Parameters: queue_name(str): The name of the queue being declared.

(self, queue_name: str)

        self.emit_after("declare_actor", actor)

    def declare_queue(self, queue_name: str) -> None:  # pragma: no cover
        """Declare a queue on this broker.  This method must be
        idempotent.

        Parameters:
          queue_name(str): The name of the queue being declared.
        """
        raise NotImplementedError

    def enqueue(self, message: Message, *, delay: Optional[int] = None) -> Message:  # pragma: no cover
        """Enqueue a message on this broker.