1.1.5 • Published 9 months ago

smq-rabbitmq-queue v1.1.5

Weekly downloads
-
License
ISC
Repository
-
Last release
9 months ago

simple wrapper for rabbitmq or redis-smq with multiple consumer .

use unified api for both

const conf = {
  // isRabbitMQ: true // use rabbitmq without this is use redis
  QueueName: 'amqp_queue',
  DB: 0,
  host: '127.0.0.1',
  port: 6379,
  password: '123456',
}
const messageHandler = async (payload) => {
console.log(payload)
}
const q = new QueuePipe(conf);
await q.setConsumer(messageHandler)
const q = new QueuePipe(conf); // same conf as consumer
const prod = await q.getProducer()
prod.publish({
// payload
})
1.1.1

9 months ago

1.1.0

9 months ago

1.1.5

9 months ago

1.1.4

9 months ago

1.1.2

9 months ago

1.0.22

9 months ago

1.0.21

9 months ago

1.0.20

9 months ago

1.0.26

9 months ago

1.0.25

9 months ago

1.0.24

9 months ago

1.0.23

9 months ago

1.0.19

11 months ago

1.0.18

11 months ago

1.0.17

11 months ago

1.0.16

11 months ago

1.0.8

1 year ago

1.0.7

1 year ago

1.0.6

1 year ago

1.0.11

1 year ago

1.0.10

1 year ago

1.0.15

11 months ago

1.0.14

12 months ago

1.0.13

12 months ago

1.0.12

12 months ago

1.0.5

1 year ago

1.0.4

1 year ago

1.0.3

1 year ago

1.0.2

1 year ago

1.0.1

1 year ago

1.0.0

1 year ago