1.1.5 • Published 7 months ago

smq-rabbitmq-queue v1.1.5

Weekly downloads
-
License
ISC
Repository
-
Last release
7 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

7 months ago

1.1.0

7 months ago

1.1.5

7 months ago

1.1.4

7 months ago

1.1.2

7 months ago

1.0.22

7 months ago

1.0.21

7 months ago

1.0.20

7 months ago

1.0.26

7 months ago

1.0.25

7 months ago

1.0.24

7 months ago

1.0.23

7 months ago

1.0.19

9 months ago

1.0.18

9 months ago

1.0.17

9 months ago

1.0.16

9 months ago

1.0.8

10 months ago

1.0.7

10 months ago

1.0.6

10 months ago

1.0.11

10 months ago

1.0.10

10 months ago

1.0.15

9 months ago

1.0.14

10 months ago

1.0.13

10 months ago

1.0.12

10 months ago

1.0.5

11 months ago

1.0.4

11 months ago

1.0.3

11 months ago

1.0.2

1 year ago

1.0.1

1 year ago

1.0.0

1 year ago