gen_rmq v3.0.0 GenRMQ.Processor behaviour 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

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