1.7.0 • Published 1 year ago

@galenjs/amqp v1.7.0

Weekly downloads
-
License
ISC
Repository
github
Last release
1 year ago

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