1.1.5 • Published 9 months ago
smq-rabbitmq-queue v1.1.5
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