minty-amqp 0.3.2

开始

主要：

def main():
    amqp = AMQPLoader(
        domains=[insert_domains_here],
        command_wrapper_middleware=[insert_wrapper_classes_here],
        config_path="config.conf",
    )
    amqp.start_client()

创建消费者：

from minty_amqp.consumer import BaseConsumer

class ConsumerPrint(BaseConsumer):
  def __call__(self, message):
      print("Message:", message.body, "consumer_touch")
      message.ack()

package.conf示例：

<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>

注意：死信交换配置是可选的

更多文档

有关此操作的详细信息，请参阅通过CI生成的文档 模块以及如何在我们的在线文档中做出贡献。打开index.html 当你到达那里： https://gitlab.com/minty-python/minty_amqp/-/jobs/artifacts/master/browse/tmp/docs?job=qa

贡献

请阅读CONTRIBUTING.md 有关我们的行为准则以及向我们提交请求的过程的详细信息。

版本控制

我们使用SemVer进行版本控制。对于版本 可用，请参阅 tags on this repository

许可证

版权所有（c）2018，Minty Team和 CONTRIBUTORS

这个项目是根据eupl，v1.2授权的。见 EUPL-1.2.txt 文件以获取详细信息。