feat: allow to set db number

resolves #62
NezuChan · Dec 2, 2022 · 600be59 · 600be59
1 parent e57a8ed
commit 600be59
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/.env_example b/.env_example
@@ -4,5 +4,6 @@ REDIS_HOST = "localhost"
 REDIS_PORT = 6379
 REDIS_USERNAME = 
 REDIS_PASSWORD =
+REDIS_DB = 
 AMQP_HOST = "amqp://guest:guest@localhost"
 AMQP_QUEUE_NAME = "scheduled-tasks"
diff --git a/src/Structures/TaskManager.ts b/src/Structures/TaskManager.ts
@@ -19,12 +19,14 @@ export class TaskManager extends EventEmitter {
     public amqpSender!: RoutingPublisher<string, Record<string, any>>;
     public amqpReceiver!: RpcSubscriber<string, Record<string, any>>;
     public amqpReceiverCluster!: RpcSubscriber<string, Record<string, any>>;
+
     public bull = new Bull(`${process.env.QUEUE_NAME ?? "scheduled-tasks"}-cluster-${this.clusterId}`, {
         redis: {
             host: process.env.REDIS_HOST!,
             port: parseInt(process.env.REDIS_PORT!),
             username: process.env.REDIS_USERNAME,
-            password: process.env.REDIS_PASSWORD
+            password: process.env.REDIS_PASSWORD,
+            db: parseInt(process.env.REDIS_DB!)
         },
         defaultJobOptions: {
             removeOnComplete: true,