From 648be3005fd8436a9dbcc43216530677df3337a2 Mon Sep 17 00:00:00 2001 From: MeiMei <30769358+mei23@users.noreply.github.com> Date: Sun, 15 Dec 2019 03:35:09 +0900 Subject: [PATCH] Fix #5637 (#5638) --- src/server/api/streaming.ts | 2 +- src/services/stream.ts | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/server/api/streaming.ts b/src/server/api/streaming.ts index 902c62ef9..ee71f4604 100644 --- a/src/server/api/streaming.ts +++ b/src/server/api/streaming.ts @@ -26,7 +26,7 @@ module.exports = (server: http.Server) => { const subscriber = redis.createClient( config.redis.port, config.redis.host); - subscriber.subscribe('misskey'); + subscriber.subscribe(config.host); ev = new EventEmitter(); diff --git a/src/services/stream.ts b/src/services/stream.ts index a47798eef..32b990ced 100644 --- a/src/services/stream.ts +++ b/src/services/stream.ts @@ -4,6 +4,7 @@ import { Note } from '../models/entities/note'; import { UserList } from '../models/entities/user-list'; import { ReversiGame } from '../models/entities/games/reversi/game'; import { UserGroup } from '../models/entities/user-group'; +import config from '../config'; class Publisher { private publish = (channel: string, type: string | null, value?: any): void => { @@ -11,7 +12,7 @@ class Publisher { { type: type, body: null } : { type: type, body: value }; - redis.publish('misskey', JSON.stringify({ + redis.publish(config.host, JSON.stringify({ channel: channel, message: message }));