smq-rabbitmq-queue
v1.0.2
Published
simple wrapper for rabbitmq or redis-smq with multiple consumer .
Downloads
97
Readme
simple wrapper for rabbitmq or redis-smq with multiple consumer .
use unified api for both
class QueuePipe extends BaseMqInterface{
constructor(config, isCluster=null) {
super()
if (config.isRabbitMQ) { // your custom config
return new RabbitMQPipe(config, isCluster)
} else {
return new SMQPipe(config, isCluster)
}
}
}