Kombu.Broadcast (Kombu v0.1.0)

Copy Markdown View Source

Convenience module for creating broadcast queues (kombu.common.Broadcast).

Every broadcast queue instance gets a unique queue name ("bcast.<uuid>") with auto_delete: true bound to a "fanout" exchange named name.

Summary

Functions

new(name \\ nil, opts \\ [])

Creates a broadcast %Kombu.Queue{} bound to a fanout exchange.

Functions

new(name \\ nil, opts \\ [])

@spec new(String.t() | nil, keyword()) :: Kombu.Queue.t()

Creates a broadcast %Kombu.Queue{} bound to a fanout exchange.