summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/MetaService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2023-04-09 17:09:27 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2023-04-09 17:09:27 +0900
commit39cf80e19f10676b263004e0a1402fdc5a9613f9 (patch)
treea39d41c80ef6b33dc1a4be12ebd2fbe00f89bf11 /packages/backend/src/core/MetaService.ts
parentfix(backend): ストリーミングのLTLチャンネルでサーバー側に... (diff)
downloadsharkey-39cf80e19f10676b263004e0a1402fdc5a9613f9.tar.gz
sharkey-39cf80e19f10676b263004e0a1402fdc5a9613f9.tar.bz2
sharkey-39cf80e19f10676b263004e0a1402fdc5a9613f9.zip
fix(backend): イベント用redis分離が上手く動かない問題を修正
Diffstat (limited to 'packages/backend/src/core/MetaService.ts')
-rw-r--r--packages/backend/src/core/MetaService.ts8
1 files changed, 4 insertions, 4 deletions
diff --git a/packages/backend/src/core/MetaService.ts b/packages/backend/src/core/MetaService.ts
index 2b6160c82e..1322927c2c 100644
--- a/packages/backend/src/core/MetaService.ts
+++ b/packages/backend/src/core/MetaService.ts
@@ -14,8 +14,8 @@ export class MetaService implements OnApplicationShutdown {
private intervalId: NodeJS.Timer;
constructor(
- @Inject(DI.redisForPubsub)
- private redisForPubsub: Redis.Redis,
+ @Inject(DI.redisForSub)
+ private redisForSub: Redis.Redis,
@Inject(DI.db)
private db: DataSource,
@@ -33,7 +33,7 @@ export class MetaService implements OnApplicationShutdown {
}, 1000 * 60 * 5);
}
- this.redisForPubsub.on('message', this.onMessage);
+ this.redisForSub.on('message', this.onMessage);
}
@bindThis
@@ -122,6 +122,6 @@ export class MetaService implements OnApplicationShutdown {
@bindThis
public onApplicationShutdown(signal?: string | undefined) {
clearInterval(this.intervalId);
- this.redisForPubsub.off('message', this.onMessage);
+ this.redisForSub.off('message', this.onMessage);
}
}