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
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