summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/RoleService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-04-07 11:20:14 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-04-07 11:20:14 +0900
commitff6d9d28604d173b57bdb26b94ccd16bd0f4c4ba (patch)
tree7d608de794ce10af14f954d753ce2d86501ca5c7 /packages/backend/src/core/RoleService.ts
parentperf(backend): reduce db query (diff)
downloadmisskey-ff6d9d28604d173b57bdb26b94ccd16bd0f4c4ba.tar.gz
misskey-ff6d9d28604d173b57bdb26b94ccd16bd0f4c4ba.tar.bz2
misskey-ff6d9d28604d173b57bdb26b94ccd16bd0f4c4ba.zip
feat(backend): イベント用Redisを別サーバーに分離できるように
Diffstat (limited to 'packages/backend/src/core/RoleService.ts')
-rw-r--r--packages/backend/src/core/RoleService.ts8
1 files changed, 4 insertions, 4 deletions
diff --git a/packages/backend/src/core/RoleService.ts b/packages/backend/src/core/RoleService.ts
index 54e098ea52..3379f5af8b 100644
--- a/packages/backend/src/core/RoleService.ts
+++ b/packages/backend/src/core/RoleService.ts
@@ -64,8 +64,8 @@ export class RoleService implements OnApplicationShutdown {
public static NotAssignedError = class extends Error {};
constructor(
- @Inject(DI.redisSubscriber)
- private redisSubscriber: Redis.Redis,
+ @Inject(DI.redisForPubsub)
+ private redisForPubsub: Redis.Redis,
@Inject(DI.usersRepository)
private usersRepository: UsersRepository,
@@ -87,7 +87,7 @@ export class RoleService implements OnApplicationShutdown {
this.rolesCache = new MemorySingleCache<Role[]>(Infinity);
this.roleAssignmentByUserIdCache = new MemoryKVCache<RoleAssignment[]>(Infinity);
- this.redisSubscriber.on('message', this.onMessage);
+ this.redisForPubsub.on('message', this.onMessage);
}
@bindThis
@@ -400,6 +400,6 @@ export class RoleService implements OnApplicationShutdown {
@bindThis
public onApplicationShutdown(signal?: string | undefined) {
- this.redisSubscriber.off('message', this.onMessage);
+ this.redisForPubsub.off('message', this.onMessage);
}
}