smq-rabbitmq-queue v1.0.2

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