subscribex v0.9.0 Subscribex.Subscriber behaviour

Summary

Types

body()

channel()

ignored()

payload()

redelivered()

Functions

ack(channel, delivery_tag)

child_spec(arg)

Returns a specification to start this module under a supervisor

init(arg)

Callback implementation for c:GenServer.init/1

preprocess(payload, channel, delivery_tag, preprocessors)

publish(channel, exchange, routing_key, payload)

raise_invalid_config(module, message, returned_value)

reject(channel, delivery_tag, options)

start_link(callback_module, opts \\ [])

Callbacks

handle_error(payload, channel, arg2, arg3)

handle_payload(payload, channel, arg2, redelivered)

init()

Types

body :: String.t

channel :: %AMQP.Channel{conn: term, pid: term}

ignored :: term

payload :: term

redelivered :: boolean

Functions

ack(channel, delivery_tag)

child_spec(arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

init(arg)

Callback implementation for c:GenServer.init/1.

preprocess(payload, channel, delivery_tag, preprocessors)

publish(channel, exchange, routing_key, payload)

raise_invalid_config(module, message, returned_value)

reject(channel, delivery_tag, options)

start_link(callback_module, opts \\ [])

Callbacks

handle_error(payload, channel, arg2, arg3)

Specs

handle_error(payload, channel, Subscribex.delivery_tag, RuntimeError.t) :: ignored

handle_payload(payload, channel, arg2, redelivered)

Specs

handle_payload(payload, channel, Subscribex.delivery_tag, redelivered) ::
  {:ok, :ack} |
  {:ok, :manual}

init()

Specs

init :: {:ok, %Subscribex.Subscriber.Config{auto_ack: term, binding_opts: term, broker: term, dead_letter_exchange: term, dead_letter_exchange_opts: term, dead_letter_exchange_type: term, dead_letter_queue: term, dead_letter_queue_opts: term, dl_binding_opts: term, exchange: term, exchange_opts: term, exchange_type: term, prefetch_count: term, queue: term, queue_opts: term}}