Update queue name validation

mugli · Oct 5, 2019 · 836d8e2 · 836d8e2
1 parent 8057690
commit 836d8e2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/consumer.ts b/src/consumer.ts
@@ -47,8 +47,8 @@ export class Consumer {
       throw new Error('workerFn is required');
     }
 
-    if (!qname) {
-      throw new Error('qname is required');
+    if (!qname || qname === defaultOptions.INTERNALS) {
+      throw new Error(`qname cannot be empty or set as "${defaultOptions.INTERNALS}"`);
     }
 
     this.consumers = [];

diff --git a/src/producer.ts b/src/producer.ts
@@ -38,8 +38,8 @@ export class Producer {
       this._redis = new IORedis(this._redisOptions) as Redis;
     }
 
-    if (!qname) {
-      throw new Error('qname is required');
+    if (!qname || qname === defaultOptions.INTERNALS) {
+      throw new Error(`qname cannot be empty or set as "${defaultOptions.INTERNALS}"`);
     }
 
     this._QNAME = `${defaultOptions.NAMESPACE}:queue:${qname}`;