From 80f8f2465ec99e0c06b8e9c74bdc558f5f91a6e6 Mon Sep 17 00:00:00 2001 From: Brian Gough Date: Thu, 11 Jul 2019 11:10:33 +0100 Subject: [PATCH] remove unused pubsub client --- services/real-time/app/coffee/DocumentUpdaterController.coffee | 2 +- services/real-time/app/coffee/WebsocketLoadBalancer.coffee | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/services/real-time/app/coffee/DocumentUpdaterController.coffee b/services/real-time/app/coffee/DocumentUpdaterController.coffee index b3706f47ba..a7d174cace 100644 --- a/services/real-time/app/coffee/DocumentUpdaterController.coffee +++ b/services/real-time/app/coffee/DocumentUpdaterController.coffee @@ -11,7 +11,7 @@ MESSAGE_SIZE_LOG_LIMIT = 1024 * 1024 # 1Mb module.exports = DocumentUpdaterController = # DocumentUpdaterController is responsible for updates that come via Redis # Pub/Sub from the document updater. - rclientList: RedisClientManager.createClientList(settings.redis.pubsub, settings.redis.unusedpubsub) + rclientList: RedisClientManager.createClientList(settings.redis.pubsub) listenForUpdatesFromDocumentUpdater: (io) -> logger.log {rclients: @rclientList.length}, "listening for applied-ops events" diff --git a/services/real-time/app/coffee/WebsocketLoadBalancer.coffee b/services/real-time/app/coffee/WebsocketLoadBalancer.coffee index 10f0c0c646..6de7b7c4e7 100644 --- a/services/real-time/app/coffee/WebsocketLoadBalancer.coffee +++ b/services/real-time/app/coffee/WebsocketLoadBalancer.coffee @@ -7,7 +7,7 @@ HealthCheckManager = require "./HealthCheckManager" module.exports = WebsocketLoadBalancer = rclientPubList: RedisClientManager.createClientList(Settings.redis.pubsub) - rclientSubList: RedisClientManager.createClientList(Settings.redis.pubsub, Settings.redis.unusedpubsub) + rclientSubList: RedisClientManager.createClientList(Settings.redis.pubsub) emitToRoom: (room_id, message, payload...) -> if !room_id?