Throw error if queue name is not provided

mugli · Oct 5, 2019 · d72d95c · d72d95c
1 parent f85dccb
commit d72d95c
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/src/consumer.ts b/src/consumer.ts
@@ -47,6 +47,10 @@ export class Consumer {
       throw new Error('workerFn is required');
     }
 
+    if (!qname) {
+      throw new Error('qname is required');
+    }
+
     this.consumers = [];
     for (let i = 0; i < this.concurrency; i++) {
       const consumer = new ConsumerUnit(qname, workerFn, options);

diff --git a/src/producer.ts b/src/producer.ts
@@ -38,6 +38,10 @@ export class Producer {
       this._redis = new IORedis(this._redisOptions) as Redis;
     }
 
+    if (!qname) {
+      throw new Error('qname is required');
+    }
+
     this._QNAME = `${defaultOptions.NAMESPACE}:queue:${qname}`;
     this._DEDUPSET = `${defaultOptions.NAMESPACE}:queue:${qname}:dedupset`;