Yggdrasil.RabbitMQ.Channel.Generator (Yggdrasil for RabbitMQ v6.0.0) View Source

This module defines a supervisor for creating channels on demand.

Link to this section Summary

Functions

Returns a specification to start this module under a supervisor.

Looks up a RabbitMQ channel for a client.

Runs a supervised RabbitMQ channel for a client using a RabbitMQ connection.

Starts a chanel generator.

Stops a channel generator. Optionally, it receives a reason (defaults to :normal) and a timeout (default to :infinity).

Link to this section Functions

Returns a specification to start this module under a supervisor.

See Supervisor.

Specs

lookup(Yggdrasil.RabbitMQ.Client.t()) ::
  {:ok, AMQP.Channel.t()} | {:error, term()}

Looks up a RabbitMQ channel for a client.

Link to this function

open(client, connection)

View Source

Specs

open(Yggdrasil.RabbitMQ.Client.t(), AMQP.Connection.t()) ::
  {:ok, AMQP.Channel.t()} | {:error, term()}

Runs a supervised RabbitMQ channel for a client using a RabbitMQ connection.

Link to this function

start_link(options \\ [])

View Source

Specs

Starts a chanel generator.

Link to this function

stop(generator, reason \\ :normal, timeout \\ :infinity)

View Source

Specs

stop(Supervisor.supervisor(), term(), :infinity | non_neg_integer()) :: :ok

Stops a channel generator. Optionally, it receives a reason (defaults to :normal) and a timeout (default to :infinity).