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