klg-mq

2019-12-03 admin

klg-mq是什么

什么是klg-mq,message queue

klg-mq使用教程帮助文档

klg-mq

rabbitmq 连接工具

QuickStart

// 初始化
const mq = new Rabbitmq('amqp://joda:5672', 'test:')

// 发送消息
const queueName = 'a1'
const data = {a: 'ssss', b: 233}
await mq.queue(queueName, data)

// 消费(异步)
const prefetch = 2 // 消费速率
mq.consumeSingleQueue(queueName, prefetch, async function (data) {
  expect(data).toEqual({a: 'ssss', b: 233})
  done()
})

// 暂停消费 一般用于服务平滑重启
mq.disable()

// 重新激活
mq.active()

Test

没有做 mq mock,所以需要 mq 服务,开启 mq 服务,然后修改测试文件 Rabbitmq.test.ts 里 初始化连接的 url

$ npm i
$ npm test

History

1.1.1 默认所有消息都会持久化 persistent

你可能感兴趣的文章:

本站文章除注明转载外,均为本站原创或编译。欢迎任何形式的转载,但请务必注明出处。

转载请注明:文章转载自 JavaScript中文网 [https://www.javascriptcn.com]

本文地址:https://www.javascriptcn.com/read-80302.html

文章标题:klg-mq

回到顶部