AMQPStorm Documentation
Thread-safe Python RabbitMQ Client & Management library.
Installation
The latest version can be installed using pip and is available at pypi here
pip install amqpstorm
You can also install AMQPStorm with the management dependencies using.
pip install amqpstorm[management]
You can also install AMQPStorm with the pool dependencies using.
pip install amqpstorm[pool]
Basic Example
with amqpstorm.Connection('rmq.amqpstorm.io', 'guest', 'guest') as connection:
with connection.channel() as channel:
channel.queue.declare('fruits')
message = amqpstorm.Message.create(
channel, body='Hello RabbitMQ!', properties={
'content_type': 'text/plain'
})
message.publish('fruits')
Additional Examples
A wide verity of examples are available on Github at here
Usage
Management API Usage
Examples
Pool Examples
Issues
Please report any issues on Github here
Source
AMQPStorm source code is available on Github here