gen_rmq v1.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()}