View Source Lapin.Exchange (lapin v2.0.0)

Lapin Exchange

Summary

name()

routing_key()

t()

Exchange

type()

new(name, attrs)

@type name() :: String.t()

@type routing_key() :: String.t()

@type t() :: %Lapin.Exchange{
  binds: [],
  name: name(),
  options: Keyword.t(),
  type: type()
}

Exchange

@type type() :: :direct | :fanout | :topic

@spec declare(t(), AMQP.Channel.t()) :: :ok | {:error, term()}

@spec new(String.t(), Keyword.t()) :: %Lapin.Exchange{
  binds: term(),
  name: term(),
  options: term(),
  type: term()
}