diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2023-04-07 11:33:15 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2023-04-07 11:33:15 +0900 |
| commit | 1e3fb5531b4ee18bb9939a4ae25beea14cb6b0b5 (patch) | |
| tree | 05b920c6990c1ce6ccf0c6bf50151860abc1398f /packages/backend/src/core/CacheService.ts | |
| parent | feat(backend): ジョブキュー用Redisを別サーバーに分離できる... (diff) | |
| download | sharkey-1e3fb5531b4ee18bb9939a4ae25beea14cb6b0b5.tar.gz sharkey-1e3fb5531b4ee18bb9939a4ae25beea14cb6b0b5.tar.bz2 sharkey-1e3fb5531b4ee18bb9939a4ae25beea14cb6b0b5.zip | |
typo
Diffstat (limited to 'packages/backend/src/core/CacheService.ts')
| -rw-r--r-- | packages/backend/src/core/CacheService.ts | 8 |
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); } } |