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')