summaryrefslogtreecommitdiff
path: root/packages/backend/src
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-04-07 11:33:15 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-04-07 11:33:15 +0900
commit1e3fb5531b4ee18bb9939a4ae25beea14cb6b0b5 (patch)
tree05b920c6990c1ce6ccf0c6bf50151860abc1398f /packages/backend/src
parentfeat(backend): ジョブキュー用Redisを別サーバーに分離できる... (diff)
downloadsharkey-1e3fb5531b4ee18bb9939a4ae25beea14cb6b0b5.tar.gz
sharkey-1e3fb5531b4ee18bb9939a4ae25beea14cb6b0b5.tar.bz2
sharkey-1e3fb5531b4ee18bb9939a4ae25beea14cb6b0b5.zip
typo
Diffstat (limited to 'packages/backend/src')
-rw-r--r--packages/backend/src/core/CacheService.ts8
1 files changed, 4 insertions, 4 deletions
diff --git a/packages/backend/src/core/CacheService.ts b/packages/backend/src/core/CacheService.ts
index f0c311b9b0..d74f3e8788 100644
--- a/packages/backend/src/core/CacheService.ts
+++ b/packages/backend/src/core/CacheService.ts
@@ -27,8 +27,8 @@ export class CacheService implements OnApplicationShutdown {
@Inject(DI.redis)
private redisClient: Redis.Redis,
- @Inject(DI.redisSubscriber)
- private redisSubscriber: Redis.Redis,
+ @Inject(DI.redisForPubsub)
+ private redisForPubsub: Redis.Redis,
@Inject(DI.usersRepository)
private usersRepository: UsersRepository,
@@ -116,7 +116,7 @@ export class CacheService implements OnApplicationShutdown {
fromRedisConverter: (value) => new Set(JSON.parse(value)),
});
- this.redisSubscriber.on('message', this.onMessage);
+ this.redisForPubsub.on('message', this.onMessage);
}
@bindThis
@@ -167,6 +167,6 @@ export class CacheService implements OnApplicationShutdown {
@bindThis
public onApplicationShutdown(signal?: string | undefined) {
- this.redisSubscriber.off('message', this.onMessage);
+ this.redisForPubsub.off('message', this.onMessage);
}
}