host# casual --help queue
queue [0..1]
queue related administration
SUB OPTIONS
-q, --list-queues [0..1]
list information of all queues in current domain
-z, --list-zombies [0..1]
list information of all zombie queues in current domain
-r, --list-remote [0..1]
list all remote discovered queues
-g, --list-groups [0..1]
list information of all groups in current domain
-m, --list-messages [0..1] (<queue>) [1]
list information of all messages of the provided queue
--list-forward-services [0..1]
list information of all service forwards
--list-forward-queues [0..1]
list information of all queue forwards
--list-forward-groups [0..1]
list (aggregated) information of forward groups
--restore [0..1] (<queue>) [0..*]
restores messages to queue
Messages will be restored to the queue they first was enqueued to (within the same queue-group)
Example:
casual queue --restore <queue-name>
-e, --enqueue [0..1] (<queue>) [1]
enqueue buffer(s) to a queue from stdin
Assumes a conformant buffer(s)
Example:
cat somefile.bin | casual queue --enqueue <queue-name>
@note: part of casual-pipe
-d, --dequeue [0..1] (<queue>, [<id>]) [1..2]
dequeue message from a queue to `casual-pipe`
if id is absent the oldest available message is dequeued.
Example:
casual queue --dequeue <queue> | <some other part in casual-pipe> | ... | <casual-pipe termination>
casual queue --dequeue <queue> <id> | <some other part in casual-pipe> | ... | <casual-pipe termination>
@note: part of casual-pipe
-p, --peek [0..1] (<queue>, [<id>]) [1..*]
peeks messages from the give queue and streams them to casual-pipe
Example:
casual queue --peek <queue-name> <id1> <id2> | <some other part of casual-pipe> | ... | <casual-pipe-termination>
@note: part of casual-pipe
--consume [0..1] (<queue>, <count>) [1..2]
consumes up to `count` messages from the provided `queue` and send it downstream
Example:
casual queue --consume <queue-name> [<count>] | <some other part of casual-pipe> | ... | <casual-pipe-termination>
@note: part of casual-pipe
--attributes [0..1] (<attribute-name>, <value>) [2..* {2}]
INCUBATION - adds or mutates queue message attributes on piped messages
@attention INCUBATION - might change during. or in between minor version.
Valid attributes:
* properties | user defined string
* reply | queue name
* available | absolute time since epoch ([+]?<value>[h|min|s|ms|us|ns])+
Example:
`$ casual queue --dequeue a | casual queue --attributes reply a.reply properties foo | casual queue --enqueue a`
@note: Can be used to add queue attributes to a service reply_
@note: part of casual-pipe
--clear [0..1] (<queue>) [1..*]
clears all messages from provided queues
Example:
casual queue --clear a b c
--remove-messages [0..1] (<queue>, <id>) [2..*]
removes specific messages from a given queue
--recover-transactions-commit [0..1] (<gtrid>) [1..*]
recover specific messages from a given queue with commit
--recover-transactions-rollback [0..1] (<gtrid>) [1..*]
recover specific messages from a given queue with rollback
--forward-scale-aliases [0..1] (<alias>, <# instances>) [2..* {2}]
scales forward aliases to the requested number of instances
Example:
casual queue --forward-scale-aliases a 2 b 0 c 10
--metric-reset [0..1] (<queue>) [1..*]
resets metrics for the provided queues
if no queues are provided, metrics for all queues are reset.
Example:
casual queue --metric-reset a b
--legend [0..1] (list-queues, list-messages, list-forward-groups, list-forward-services, list-forward-queues) [1]
provide legend for the output for some of the options
to view legend for --list-queues use casual queue --legend list-queues, and so on.
use auto-complete to help which options has legends
--information [0..1]
collect aggregated information about queues in this domain
--state [0..1] (json, yaml, xml, ini, line) [0..1]
prints state in the provided format to stdout