diff options
| author | MeiMei <30769358+mei23@users.noreply.github.com> | 2019-12-15 03:35:09 +0900 |
|---|---|---|
| committer | syuilo <Syuilotan@yahoo.co.jp> | 2019-12-15 03:35:09 +0900 |
| commit | 648be3005fd8436a9dbcc43216530677df3337a2 (patch) | |
| tree | 8d260bd7471b0fea6dab6e55000aef0401df1097 /src | |
| parent | Redis prefixにホスト名を使用するように (Resolve #5639) (#5640) (diff) | |
| download | misskey-648be3005fd8436a9dbcc43216530677df3337a2.tar.gz misskey-648be3005fd8436a9dbcc43216530677df3337a2.tar.bz2 misskey-648be3005fd8436a9dbcc43216530677df3337a2.zip | |
Fix #5637 (#5638)
Diffstat (limited to 'src')
| -rw-r--r-- | src/server/api/streaming.ts | 2 | ||||
| -rw-r--r-- | 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 902c62ef98..ee71f4604c 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 a47798eefd..32b990ced7 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 })); |