coney

v2.1.0

coney v2.1.0 Coney.Consumer behaviour

Link to this section Summary

Types

stacktrace()

Callbacks

connection()
error_happend(exception, message, meta)
error_happend(exception, stacktrace, message, meta)
parse(message, meta)
process(payload, meta)

Link to this section Types

Link to this type stacktrace() 
stacktrace() :: []

Link to this section Callbacks

Link to this callback connection() (optional) 
connection() :: map()
Link to this callback error_happend(exception, message, meta) (optional) 
error_happend(exception :: struct(), message :: binary(), meta :: map()) ::
  :ok | :reject | :redeliver | {:reply, binary()}
Link to this callback error_happend(exception, stacktrace, message, meta) (optional) 
error_happend(
  exception :: struct(),
  stacktrace :: stacktrace(),
  message :: binary(),
  meta :: map()
) :: :ok | :reject | :redeliver | {:reply, binary()}
Link to this callback parse(message, meta) 
parse(message :: binary(), meta :: map()) :: any()
Link to this callback process(payload, meta) 
process(payload :: any(), meta :: map()) ::
  :ok | :reject | :redeliver | {:reply, binary()}