Requirements

• Python 3.6+

• python-qpid-proton

• PyYAML

Installation

Qpid Bow is available from PyPI:

$ pip install qpid-bow

Or add qpid-bow to your application’s requirements using requirements.txt / setup.py / Pipfile.

Testing

Qpid Bow’s unit tests need to connect to an actual Apache Qpid server for all tests to succeed. By default the tests assume a server exists on localhost.

To specify the server address to use for tests use the environment variable: AMQP_TEST_SERVERS

Available tools

Queue

• qb queue create - Create queues.

• qb queue delete - Delete queues.

• qb queue purge - Purge messages from a queue.

• qb queue reroute - Reroute messages from a queue to an exchange.

• qb queue stats - Print queue usage statistics and active number of messages.

Message

• qb message receive - Receive messages from a queue or an exchange.

• qb message send - Send messages to a queue or an exchange.

Route

• qb route dump - View & save exchange -> queue routing.

• qb route config - Setup exchange -> queue routing from a saved file.

Connection

• qb connection kill - Kill connections from the server.

Session

• qb session outgoing - List outgoing sessions from the server.

Configuration & Environment variables

Several options exist to configure Qpid Bow. In order of preference:

Pass in arguments One can always override the used server URL using arguments:

• For the CLI tools, use the --broker-url command line argument.

• For the library pass in the keyword argument server_url.

Configure using a dict When using Qpid Bow as a library, one can pass in config using a dict to: qpid_bow.config.configure

The dict can contain the following entries:

• amqp_url - Comma-separated list of main and failover servers to connect to.

• username - Username to use when no username is provided in the URL.

• password - Password to use when no password is provided in the URL.

Environment variables The easiest way to configure Qpid Bow’s tools and library is to use environment variables. These variables can be added to your shell’s profile and will automatically get picked up.

• AMQP_SERVERS - Comma-separated list of main and failover servers to connect to.

• AMQP_TEST_SERVERS - Same as AMQP_SERVERS, used solely for unittests.

example: AMQP_SERVERS=amqp://user:pass@192.168.1.1:5672,amqp://user:pass@192.168.1.2:5672