mq/

Details

Path	Synopsis
kafka
rabbitMQ 1、在消费函数处理结束后再发送Ack； 2、支持设置消费协程数量，并发消费； 3、支持停止消费协程、并等待所有已经获取到的消息处理完毕，以便实现进程优雅退出	1、在消费函数处理结束后再发送Ack； 2、支持设置消费协程数量，并发消费； 3、支持停止消费协程、并等待所有已经获取到的消息处理完毕，以便实现进程优雅退出