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