Conduit

v0.12.10

Conduit

Conduit v0.12.10 Conduit.Topology.Queue View Source

Configuration for an queue

Link to this section Summary

Types

name()
opts()
t()

Functions

new(name, opts \\ [])

Creates a new Queue struct

Link to this section Types

Link to this type name() View Source 
name() :: String.t() | (() -> String.t())
Link to this type t() View Source 
t() :: %Conduit.Topology.Queue{name: String.t(), opts: Keyword.t()}

Link to this section Functions

Link to this function new(name, opts \\ []) View Source 
new(name(), opts()) :: t()

Creates a new Queue struct

If functions are passed to either argument, they will be evaluated before returning the struct.

Examples

iex> Conduit.Topology.Queue.new(“my_app.event”) %Conduit.Topology.Queue{name: “my_app.event”, opts: []} iex> Conduit.Topology.Queue.new(“my_app.event”, from: [“my_app.event_queue”]) %Conduit.Topology.Queue{name: “my_app.event”, opts: [from: [“my_app.event_queue”]]} iex> Conduit.Topology.Queue.new(fn -> “dynamic.name” end, fn -> [from: [“my_app.event_queue”]] end) %Conduit.Topology.Queue{name: “dynamic.name”, opts: [from: [“my_app.event_queue”]]}