1.1.5 • Published 7 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
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