Skip to content
Permalink
main
Switch branches/tags

Name already in use

A tag already exists with the provided branch name. Many Git commands accept both tag and branch names, so creating this branch may cause unexpected behavior. Are you sure you want to create this branch?
Go to file
 
 
Cannot retrieve contributors at this time

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

.. toctree::
   :caption: Usage
   :name: usage

   usage/connection
   usage/channel
   usage/exceptions
   usage/message

.. toctree::
   :caption: Management API Usage
   :name: api_usage

   api_usage/api
   api_usage/exception

.. toctree::
   :glob:
   :caption: Examples
   :name: examples

   examples/*

.. toctree::
   :glob:
   :caption: Pool Examples
   :name: pool_examples

   pool_examples/*

.. toctree::
   :glob:
   :caption: Management Examples
   :name: management_examples

   management_examples/*

Issues

Please report any issues on Github here

Source

AMQPStorm source code is available on Github here

Indices and tables