Skip to main content

AMQP Consumer framework 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()

package.conf example:

<amqp>
  url = 'http://0.0.0.0:5672'
  <consumer_settings>
        routing_keys = "zsnl.v2.*.*"
        queue_name = "legacy_logging_queue_test"
        exchange  =  "minty_exchange"
        qos_prefetching =  1
        consumer_class = "zsnl_amqp_consumers.consumers.LegacyLoggingConsumer"
        number_of_channels = 1
        <dead_letter_exchange>
          exchange = "minty_retry_exchange"
          retry_time_ms = 10000
        </dead_letter_exchange>
  </consumer_settings>
</amqp>

note: dead_letter_exchange config is optional

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) Minty Team and all persons listed in the file CONTRIBUTORS

This project is licensed under the EUPL, v1.2. See the EUPL-1.2.txt in the LICENSES directory for details.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

minty_amqp-4.0.0.tar.gz (11.7 kB view hashes)

Uploaded Source

Built Distribution

minty_amqp-4.0.0-py3-none-any.whl (12.1 kB view hashes)

Uploaded Python 3

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page