mqplus 0.0.2

MQ消息工具（生产者、消费者封装）。

使用手册

快速开始

1. 生产者

import mqplus

producer = mqplus.RabbitProducer("docker.kancy.top", "root", "root123")
producer.putQueue("test", "pika.test.queue")

# 注册交换机
producer.registerExchange("pika.test.exchange", 'direct')

# 注册队列
producer.registerQueue("pika.test.queue", durable=True)

# 绑定交换机很队列
producer.bind("pika.test.exchange", "pika.test.queue")

2. 消费者

import mqplus

def handle_message(data, **kwargs):
    print(kwargs)

consumer = mqplus.RabbitConsumer("docker.kancy.top", "root", "root123")
consumer.onListener("pika.test.queue", callback=handle_message)