1.7.0 • Published 1 year ago
@galenjs/amqp v1.7.0
amqp
galenjs amqp consumer and producer
Usage
install
yarn add @galenjs/amqp
// or
npm i @galenjs/amqp
// or
pnpm install @galenjs/amqp
// app.js
const Amqp = require('./index')
const amqp = new Amqp({
config: {
url: 'amqp://localhost:5672',
sub: {
test: {
pullInterval: 1000, // 默认1s拉一次消息
pullBatchSize: 5 // 每次拉5条
}
},
consumerPath: `${process.cwd()}/test`
},
logger: console
})
const start = async () => {
await amqp.setup()
}
start()
setInterval(async () => {
await amqp.send('test', 'hello world')
}, 10000)
// test/test.js
module.exports = class Test {
async onMsg (msg) {
console.log('[message]: ', msg)
}
}
1.7.0
1 year ago
1.4.1
3 years ago
1.4.0
3 years ago
1.1.6
3 years ago
1.1.5
3 years ago
1.1.4
3 years ago
1.1.1
3 years ago
1.0.25-alpha.0
3 years ago
1.0.19
3 years ago
1.0.22
3 years ago
1.0.20
3 years ago
1.0.24
3 years ago
1.0.17
3 years ago
1.0.0
4 years ago
0.7.27
4 years ago
0.7.14
4 years ago
0.7.8
4 years ago
0.7.1
4 years ago
0.7.0
4 years ago
0.6.14
4 years ago
0.5.16
4 years ago
0.5.15
4 years ago
0.6.0
4 years ago
0.5.14
4 years ago