$ qreceive amqp://amqp.zone/queue1 --count 1 &
$ qsend amqp://amqp.zone/queue1 --message hello

$ qrespond amqp://amqp.zone/requests &
$ qrequest amqp://amqp.zone/requests < requests.txt

$ qmessage --count 10 | qsend amqp://amqp.zone/queue1
$ qmessage --rate 1 | qrequest amqp://amqp.zone/requests

For more ways to build and use Docker images and packages, see the packaging README.

• findutils
• make
• python-qpid-proton
• python3-qpid-proton

$ sudo docker run -it ssorj/qtools

$ sudo dnf install dnf-plugins-core
$ sudo dnf copr enable jross/ssorj
$ sudo dnf install qtools

If you don't have dnf, use the repo files at https://copr.fedorainfracloud.org/coprs/jross/ssorj/.

$ cd /etc/yum.repos.d && sudo wget https://copr.fedorainfracloud.org/coprs/jross/ssorj/repo/epel-7/jross-ssorj-epel-7.repo
$ sudo yum install qtools

Qtools requires a newer version of python-qpid-proton than Ubuntu provides by default. Use these commands to install it from an Ubuntu PPA.

$ sudo apt-get install software-properties-common
$ sudo add-apt-repository ppa:qpid/released
$ sudo apt-get update
$ sudo apt-get install make python-qpid-proton

After this you can install from source.

By default, installs from source go to $HOME/.local. Make sure $HOME/.local/bin is in your path.

$ cd quiver/
$ make install

Use the PREFIX option to change the install location.

$ sudo make install PREFIX=/usr/local

The core commands take one or more URLs. These indicate the location of a message source or target, such as a queue or topic.

qsend ADDRESS-URL [ADDRESS-URL ...]

An address URL has optional scheme and server parts. The default scheme is 'amqp' and 'server' is '127.0.0.1:5672'. You can use the --server option to change the default server.

[SCHEME:][//SERVER/]ADDRESS

The send and request commands take message content on standard input (one message per line) or via the --message option. The --message option can be repeated.

The receive and respond commands run forever unless you use the --count option to tell them to stop after processing a given number of messages or requests.

Tools that read from or write to the console take the following options.

--input FILE          Read input from FILE
--output FILE         Write output to FILE

With a few exceptions, all the tools share these options.

-h, --help            Print help output
--verbose             Print detailed logging
--quiet               Print no logging

These commands perform one-way message transfers.

qsend URL [URLS] [OPTIONS] [< messages.txt]
qreceive URL [URLS] [OPTIONS] [> messages.txt]

qsend URL --message MESSAGE

qreceive URL --count 1
-> MESSAGE

The send command reads messages, one per line, from standard input. Alternatively, you can input messages using the --message option. The receive command prints each message it receives to standard output.

Typical usage:

$ qsend //amqp.zone/queue1 --message m1 &
$ qreceive //amqp.zone/queue1
queue1: m1

The request command sends a request and waits for a response. The respond command listens for requests, processes them, and sends responses.

qrequest URL [URLS] [OPTIONS] [< requests.txt] [> responses.txt]
qrespond URL [URLS] [OPTIONS]

qrequest URL --message REQUEST
-> RESPONSE

qrespond URL --count 1

The request command reads request messages from standard input and writes responses to standard output.

Typical usage:

$ qrespond //amqp.zone/jobs --upper &
$ qrequest //amqp.zone/jobs --message abc
ABC

This command generates message content for use by the qsend and qrequest tools.

qmessage [OPTIONS] | {qsend,qrequest}

qmessage --id ID --body CONTENT
-> MESSAGE

qmessage --count 3
-> MESSAGE
-> MESSAGE
-> MESSAGE

The output is in JSON format. The send and request tools can consume it. Usually you pipe it in, like this.

$ qmessage | qsend queue1
$ qmessage --rate 1 | qrequest //amqp.zone/jobs

This is a simple broker implementation that you can use for testing.

qbroker [--host HOST] [--port PORT]