Proca.Pipes.Connection (proca v3.0.2)

Link to this section Summary

Functions

Returns a specification to start this module under a supervisor.

Allow setting SSL client connection options

Attempts to connect to queue. It can succeed and enter status: :connected Or it can fail and enter status: :reconnecting

Reconnecting procedure - shutdown processing and schedule connection attempt after_seconds

Connect, (todo: reconnect) functionality

Link to this section Functions

Link to this function

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

Allow setting SSL client connection options

Link to this function

connection_url()

Attempts to connect to queue. It can succeed and enter status: :connected Or it can fail and enter status: :reconnecting

Link to this function

do_reconnecting(map, after_seconds)

Reconnecting procedure - shutdown processing and schedule connection attempt after_seconds

Link to this function

handle_continue(atom, st)

Connect, (todo: reconnect) functionality

Link to this function

is_connected?()

Link to this function

publish(exchange, routing_key, data)

Specs

publish(String.t(), String.t(), map()) :: :ok | :error
Link to this function

start_link(url)