View Source mix rambla.rabbit.queue (Rambla v1.2.6)
Mix task to deal with queues in the target RabbitMQ.
This is helpful to orchestrate target RabbitMQ when deploying
to docker. Allows to create, delete, purge and query status of
the queue. Also, bind
and unbind
commands are supported,
both require exchange:...
option to be passed.
Loads the setting from config :rambla, :amqp
if no connection
is provided in parameters.
Command line options
- -c - the connection string
- -o - the list of options without spaces, separated by comma
Options
Options for create
durable
- If set, keeps the Queue between restarts of the broker. Defaults to false.auto_delete
- If set, deletes the Queue once all subscribers disconnect. Defaults to false.exclusive
- If set, only one subscriber can consume from the Queue. Defaults to false.passive
- If set, raises an error unless the queue already exists. Defaults to false.no_wait
- If set, the declare operation is asynchronous. Defaults to false.arguments
- A list of arguments to pass when declaring (of type AMQP.arguments/0). See the README for more information. Defaults to [].
Options for delete
if_unused
- If set, the server will only delete the queue if it has no consumers. If the queue has consumers, it’s not deleted and an error is returned.if_empty
- If set, the server will only delete the queue if it has no messages.no_wait
- If set, the delete operation is asynchronous.
Summary
Types
@type command() :: :declare | :create | :delete | :purge | :bind | :unbind | :status