gen_rmq

v2.3.0

gen_rmq v2.3.0 GenRMQ.Processor behaviour View Source

Defines functions to implement by any AMQP processor

Link to this section Summary

Callbacks

process(message)

Link to this section Callbacks

Link to this callback

process(message)

View Source 
process(
  message :: %GenRMQ.Message{attributes: term(), payload: term(), state: term()}
) :: :ok | {:error, term()}