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

8 months ago

1.0.21

8 months ago

1.0.20

8 months ago

1.0.26

7 months ago

1.0.25

8 months ago

1.0.24

8 months ago

1.0.23

8 months ago

1.0.19

10 months ago

1.0.18

10 months ago

1.0.17

10 months ago

1.0.16

10 months ago

1.0.8

11 months ago

1.0.7

11 months ago

1.0.6

11 months ago

1.0.11

11 months ago

1.0.10

11 months ago

1.0.15

10 months ago

1.0.14

10 months ago

1.0.13

11 months ago

1.0.12

11 months ago

1.0.5

11 months ago

1.0.4

11 months ago

1.0.3

12 months ago

1.0.2

1 year ago

1.0.1

1 year ago

1.0.0

1 year ago