StepFlow.Amqp.CommonConsumer (StepFlow v0.2.7) View Source

Definition of a Common Consumer of RabbitMQ queue.

To implement a consumer,

defmodule MyModule do
  use StepFlow.Amqp.CommonConsumer, %{
    queue: "name_of_the_rabbit_mq_queue",
    consumer: &MyModule.consume/4
  }

  def consume(channel, tag, redelivered, payload) do
    ...
    Basic.ack(channel, tag)
  end
end