Yggdrasil.RabbitMQ.Connection (Yggdrasil for RabbitMQ v6.0.0) View Source

This module defines a RabbitMQ connection process.

Link to this section Summary

Types

Namespace for the connection.

Functions

Returns a specification to start this module under a supervisor.

Gets connection struct from a connection process.

Starts a RabbitMQ connection with a namespace for the configuration. Additionally, you can add GenServer options.

Stops a RabbitMQ connection. Optionally, receives a stop reason (defaults to :normal) and a timeout in milliseconds (defaults to :infinity).

Subscribes to the connection given a namespace.

Link to this section Types

Specs

namespace() :: nil | atom()

Namespace for the connection.

Link to this section Functions

Returns a specification to start this module under a supervisor.

See Supervisor.

Specs

get(GenServer.name()) :: {:ok, term()} | {:error, term()}

Gets connection struct from a connection process.

Link to this function

start_link(namespace, options \\ [])

View Source

Specs

Starts a RabbitMQ connection with a namespace for the configuration. Additionally, you can add GenServer options.

Link to this function

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

View Source

Specs

stop(GenServer.name(), term(), :infinity | non_neg_integer()) :: :ok

Stops a RabbitMQ connection. Optionally, receives a stop reason (defaults to :normal) and a timeout in milliseconds (defaults to :infinity).

Specs

subscribe(namespace()) :: :ok

Subscribes to the connection given a namespace.