Qpid Bow is a higher level client framework for Python 3.6+ to communicate with AMQP/Qpid servers combined with a set of CLI tools to manage a Qpid server.

With its CLI tools Qpid Bow provides the missing tooling you always wanted to administrate or debug your Qpid-based AMQP stack. Providing you with the power to manage queues and exchanges, setup and save routing using YAML files and various other tools.

As a framework Qpid Bow can provide you with a higher level interface on top of the low level Qpid Proton library to integrate with AMQP/Qpid queues, exchanges and Remote Procedure Call (RPC) functionality:

• Simple, callback based receiver, supporting listening for multiple queues.
• RPC calls with automatic temporary queues and callbacks.
• Queue based sender.
• Included Qpid management code for queue/exchange creation.
• Support to run under Python's asyncio event loop with async def callbacks.

• Python 3.6+
• python-qpid-proton
• PyYAML

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.

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

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.

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:[email protected]:5672,amqp://user:[email protected]:5672