GenRMQ.Processor behaviour (gen_rmq v4.0.0) View Source

Behaviour module for implementing a RabbitMQ message processor.

A message processor is typically used to separate out business logic from a consumer, to let the consumer only deal with RabbitMQ specifics.

Link to this section Summary

Callbacks

process(message)

Link to this section Callbacks

process(message)

Specs

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