From 1038c5cd0d3735f17ff331137f42dcf90aed027d Mon Sep 17 00:00:00 2001 From: Henry Oswald Date: Mon, 8 Jul 2019 11:53:42 +0100 Subject: [PATCH] send health check to pubsub channel and use different var name --- services/real-time/app.coffee | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/services/real-time/app.coffee b/services/real-time/app.coffee index 0ddfe406e9..ab45c525b4 100644 --- a/services/real-time/app.coffee +++ b/services/real-time/app.coffee @@ -134,15 +134,15 @@ if Settings.forceDrainMsDelay? if Settings.continualPubsubTraffic console.log "continualPubsubTraffic enabled" - redisClients = [redis.createClient(Settings.redis.documentupdater), redis.createClient(Settings.redis.realtime)] + redisClients = [redis.createClient(Settings.redis.documentupdater), redis.createClient(Settings.redis.pubsub)] publishJob = (channel, callback)-> checker = new HealthCheckManager(channel) logger.debug {channel:channel}, "sending pub to keep connection alive" json = JSON.stringify({health_check:true, key: checker.id, date: new Date().toString()}) - jobs = _.map redisClients, (rclient)-> + jobs = _.map redisClients, (checkRclient)-> return (cb)-> - rclient.publish channel, json, (err)-> + checkRclient.publish channel, json, (err)-> if err? logger.err {err, channel}, "error publishing pubsub traffic to redis" return cb(err)