herald

v0.1.0-beta.3

herald v0.1.0-beta.3 Herald.Message.Processing

Responsible for processing messages.

Link to this section Summary

Types

config()
source()

Functions

perform(atom, payload, map1, map2)

Link to this section Types

Link to this type

config()

config() ::
  {queue :: String.t(), schema :: atom(), processor :: (... -> any()),
   [{:channel, AMQP.Channel.t()}]}
Link to this type

source()

source() :: :amqp

Link to this section Functions

Link to this function

perform(atom, payload, map1, map2)

perform(source(), String.t(), config(), map()) :: :ok | {:error, any()}