ConduitAMQP

v0.6.4

ConduitAMQP v0.6.4 ConduitAMQP View Source

AMQP adapter for Conduit.

  • url - Full connection url. Can be used instead of the individual connection options. Default is amqp://guest:guest@localhost:5672/.
  • host - Hostname of the broker (defaults to "localhost");
  • port - Port the broker is listening on (defaults to 5672);
  • username - Username to connect to the broker as (defaults to "guest");
  • password - Password to connect to the broker with (defaults to "guest");
  • virtual_host - Name of a virtual host in the broker (defaults to "/");
  • heartbeat - Hearbeat interval in seconds (defaults to 0 - turned off);
  • connection_timeout - Connection timeout in milliseconds (defaults to infinity);
  • conn_pool_size - Number of active connections to the broker
  • pub_pool_size - Number of publisher channels
  • options - Extra RabbitMQ options

Link to this section Summary

Types

broker()
chan()
conn()

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor

init(list)

Callback invoked to start the supervisor and during hot code upgrades

name(broker)
publish(message, config, opts)

Callback implementation for Conduit.Adapter.publish/3

publish(broker, message, config, opts)

Callback implementation for Conduit.Adapter.publish/4

start_link(broker, topology, subscribers, opts)

Callback implementation for Conduit.Adapter.start_link/4

with_chan(broker, fun)
with_conn(broker, fun)

Link to this section Types

Link to this type

broker() View Source 
broker() :: module()

Link to this type

chan() View Source 
chan() :: AMQP.Channel.t()

Link to this type

conn() View Source 
conn() :: AMQP.Connection.t()

Link to this section Functions

Link to this function

child_spec(init_arg) View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

init(list) View Source

Callback invoked to start the supervisor and during hot code upgrades.

Developers typically invoke Supervisor.init/2 at the end of their init callback to return the proper supervision flags.

Callback implementation for Supervisor.init/1.

Link to this function

name(broker) View Source

Link to this function

publish(message, config, opts) View Source

Callback implementation for Conduit.Adapter.publish/3.

Link to this function

publish(broker, message, config, opts) View Source

Callback implementation for Conduit.Adapter.publish/4.

Link to this function

start_link(broker, topology, subscribers, opts) View Source

Callback implementation for Conduit.Adapter.start_link/4.

Link to this function

with_chan(broker, fun) View Source 
with_chan(broker(), (chan() -> term())) ::
  {:error, term()} | {:ok, term()} | term()

Link to this function

with_conn(broker, fun) View Source 
with_conn(broker(), (conn() -> term())) ::
  {:error, term()} | {:ok, term()} | term()