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

Issues

Please report any issues on Github here

Source

AMQPStorm source code is available on Github here

Indices and tables