AMQP Client for minty project
Project description
AMQP Consumer service framework.
Getting started
Main:
def main(): amqp = AMQPLoader( domains=[insert_domains_here], command_wrapper_middleware=[insert_wrapper_classes_here], config_path="config.conf", ) amqp.start_client()
Create consumer:
from minty_amqp.consumer import BaseConsumer class ConsumerPrint(BaseConsumer): def __call__(self, message): print("Message:", message.body, "consumer_touch") message.ack()
application_config.json example:
{ "config_file": "config.json", "url": "http://rabbitmq_url:6782", "consumers": [ { "routing_key": "zs.*.base.*", "queue_name": "message_print_queue", "exchange": "amq.topic", "qos_prefetching": 1, "class": "package_name.consumer.ConsumerPrint", "number_of_channels": 1 } ] }
More documentation
Please see the generated documentation via CI for more information about this module and how to contribute in our online documentation. Open index.html when you get there: https://gitlab.com/minty-python/minty_amqp/-/jobs/artifacts/master/browse/tmp/docs?job=qa
Contributing
Please read CONTRIBUTING.md for details on our code of conduct, and the process for submitting pull requests to us.
Versioning
We use SemVer for versioning. For the versions available, see the tags on this repository
License
Copyright (c) 2018, Minty Team and all persons listed in CONTRIBUTORS
This project is licensed under the EUPL, v1.2. See the EUPL-1.2.txt file for details.
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 minty_amqp-0.1.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 0ee0446e4a81be9b693b5c7a04346dc4514634f62e860012130b923e7120d961 |
|
MD5 | fc7e9ca0d23dd80fe5df6317caab3e5e |
|
BLAKE2b-256 | 0f32bb2ab237985b4ef13d51ec48a0305fa799b4f40d44870e669b8a8145d7b3 |