diff --git a/services/processor/src/redis/redis-publisher.service.ts b/services/processor/src/redis/redis-publisher.service.ts
index 0c037eb..94f9c19 100644
--- a/services/processor/src/redis/redis-publisher.service.ts
+++ b/services/processor/src/redis/redis-publisher.service.ts
@@ -30,10 +30,12 @@ export class RedisPublisherService implements OnModuleInit, OnModuleDestroy {
   async onModuleInit() {
     const host = this.config.get('REDIS_HOST', 'localhost');
     const port = this.config.get('REDIS_PORT', 6379);
+    const password = this.config.get<string>('REDIS_PASSWORD');
 
     this.publisher = new Redis({
       host,
       port,
+      ...(password ? { password } : {}),
       retryStrategy: (times) => {
         const delay = Math.min(times * 50, 2000);
         return delay;
diff --git a/services/processor/src/redis/redis-session.service.ts b/services/processor/src/redis/redis-session.service.ts
index 123f2d5..fa57f97 100644
--- a/services/processor/src/redis/redis-session.service.ts
+++ b/services/processor/src/redis/redis-session.service.ts
@@ -38,10 +38,12 @@ export class RedisSessionService implements OnModuleInit, OnModuleDestroy {
   async onModuleInit() {
     const host = this.config.get('REDIS_HOST', 'localhost');
     const port = this.config.get('REDIS_PORT', 6379);
+    const password = this.config.get<string>('REDIS_PASSWORD');
 
     this.redis = new Redis({
       host,
       port,
+      ...(password ? { password } : {}),
       retryStrategy: (times) => {
         const delay = Math.min(times * 50, 2000);
         return delay;