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 }));