roger

v1.3.2

roger v1.3.2 Roger.Queue View Source

Functions related to queues.

Link to this section Summary

Types

t()

Functions

define(arg)
define(type, max_workers)
make_name(partition_id, type, postfix \\ "")

Given a partition and a queue type, construct the Queue’s name for RabbitMQ

purge(partition_id, queue_type)

Flushes all messages on the given queue

setup_channel(queue)

Setup channel with needed settings for correct working inside roger

Link to this section Types

Link to this type t() View Source 
t() :: %Roger.Queue{channel: term(), confirmed: term(), consumer_tag: term(), max_workers: term(), type: term()}

Link to this section Functions

Link to this function define(type, max_workers) View Source
Link to this function make_name(partition_id, type, postfix \\ "") View Source

Given a partition and a queue type, construct the Queue’s name for RabbitMQ.

Link to this function purge(partition_id, queue_type) View Source

Flushes all messages on the given queue.

Link to this function setup_channel(queue) View Source 
setup_channel(queue :: t()) :: {atom(), t()}

Setup channel with needed settings for correct working inside roger.