### Install AMQPStorm via pip Source: https://amqpstorm.readthedocs.io Install the core AMQPStorm library using pip. ```bash pip install amqpstorm ``` -------------------------------- ### Install AMQPStorm with management dependencies Source: https://amqpstorm.readthedocs.io Install AMQPStorm including additional management dependencies. ```bash pip install amqpstorm[management] ``` -------------------------------- ### Install AMQPStorm with pool dependencies Source: https://amqpstorm.readthedocs.io Install AMQPStorm including additional pool dependencies. ```bash pip install amqpstorm[pool] ``` -------------------------------- ### Basic AMQPStorm connection and message publishing Source: https://amqpstorm.readthedocs.io Establishes a connection to RabbitMQ, opens a channel, declares a queue, and publishes a message. ```python with amqpstorm.Connection('rmq.eandersson.net', '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') ``` -------------------------------- ### User Management Source: https://amqpstorm.readthedocs.io Methods for managing RabbitMQ users and their permissions. ```APIDOC ## User Management ### Methods - **User.get()** - Retrieves user details. - **User.list()** - Lists all users. - **User.create()** - Creates a new user. - **User.delete()** - Deletes a user. - **User.get_permission()** - Gets specific user permissions. - **User.get_permissions()** - Lists all permissions for a user. - **User.set_permission()** - Sets permissions for a user. - **User.delete_permission()** - Deletes user permissions. ``` -------------------------------- ### ManagementApi Overview Source: https://amqpstorm.readthedocs.io The ManagementApi provides an interface to interact with the RabbitMQ Management plugin, enabling administrative tasks. ```APIDOC ## ManagementApi ### Description Provides access to RabbitMQ management operations including monitoring and resource configuration. ### Methods - **ManagementApi.aliveness_test()** - Performs an aliveness test on the RabbitMQ server. - **ManagementApi.nodes()** - Retrieves information about cluster nodes. - **ManagementApi.overview()** - Retrieves the RabbitMQ server overview. - **ManagementApi.top()** - Retrieves top-level statistics. - **ManagementApi.whoami()** - Retrieves information about the current authenticated user. ``` -------------------------------- ### Queue Management Source: https://amqpstorm.readthedocs.io Methods for managing RabbitMQ queues via the Management API. ```APIDOC ## Queue Management ### Methods - **Queue.get()** - Retrieves details for a specific queue. - **Queue.list()** - Lists all queues. - **Queue.declare()** - Declares a new queue. - **Queue.delete()** - Deletes a queue. - **Queue.purge()** - Purges messages from a queue. - **Queue.bindings()** - Lists bindings for a queue. - **Queue.bind()** - Binds a queue to an exchange. - **Queue.unbind()** - Unbinds a queue from an exchange. ``` === COMPLETE CONTENT === This response contains all available snippets from this library. No additional content exists. Do not make further requests.