Yggdrasil.RabbitMQ.Channel (Yggdrasil for RabbitMQ v6.0.0) View Source
This module defines a supervised RabbitMQ channel.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Gets the RabbitMQ channel for a supervised channel.
Starts a supervised channel for a client. Optionally, you can add
GenServer options.
Stops a supervised channel. Optionally, receives a stop reason (defaults
to :normal) and a timeout in milliseconds (defaults to :infinity).
Subscribes to the channel given a client.
Link to this section Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Specs
get(GenServer.server()) :: {:ok, AMQP.Channel.t()} | {:error, term()}
Gets the RabbitMQ channel for a supervised channel.
Specs
start_link(Yggdrasil.RabbitMQ.Client.t(), GenServer.options()) :: GenServer.on_start()
Starts a supervised channel for a client. Optionally, you can add
GenServer options.
Specs
stop(GenServer.server(), term(), :infinity | non_neg_integer()) :: :ok
Stops a supervised channel. Optionally, receives a stop reason (defaults
to :normal) and a timeout in milliseconds (defaults to :infinity).
Specs
subscribe(Yggdrasil.RabbitMQ.Client.t()) :: :ok
Subscribes to the channel given a client.