gen_rmq v1.3.0 GenRMQ.Processor behaviour View Source

Defines functions to implement by any AMQP processor

Link to this section Summary

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()}