Thread-safe Python RabbitMQ Client & Management library.
Project description
AMQPStorm
Thread-safe Python RabbitMQ Client & Management library.
Introduction
AMQPStorm is a library designed to be consistent, stable and thread-safe.
100% Unit-test Coverage!
Supports Python 2.6, 2.7 and Python 3.3+.
Fully tested against Python Implementations; CPython, PyPy and Pyston.
When using a SSL connection, TLSv1 or higher is required.
Documentation
Additional documentation is available on docs.amqpstorm.io.
Changelog
Version 2.2.0
Connection.close should now be more responsive.
Channels are now reset when re-opening an existing connection.
Re-wrote large portions of the Test suit.
Version 2.1.4
Added parameter to override auto-decode on incoming Messages - Thanks Travis Griggs.
Fixed a rare bug that could cause the consumer to get stuck if the connection unexpectedly dies - Thanks Connor Wolf.
Version 2.1.3
Fixed a potential recursion error in Connection.close.
Version 2.1.1
Reduced default TCP Timeout from 30s to 10s.
Connection Open/Close timeout is now three times the value of TCP Timeout.
Connection will now wait for a response from the remote server before closing.
Version 2.1.0
- [Experimental] Added support for the RabbitMQ Management Api.
Connection/Channel function check_for_errors now behave more consistently.
Version 2.0.0
- Messages are now delivered as Message objects by default.
to_tuple and to_dict are now set to False by default.
This is a breaking change that affects the following function:
channel.process_data_events
channel.start_consuming
channel.basic.get
Credits
Special thanks to gmr (Gavin M. Roy) for creating pamqp, and in addition amqpstorm is heavily influenced by his pika and rabbitpy libraries.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for AMQPStorm-2.2.0-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 0a398b70cd5a52cb83d70e3cfb5364acdb5f408e40e7bd059a2ea89659bf868f |
|
MD5 | 11740863ccef65e18e738f0dc6558a8b |
|
BLAKE2b-256 | 69d65223950a14de35b9f0e933b73e4e6981320db5a5f05216a83d9f8bd4241a |