agw/overleaf-cep
1
0
Fork 0
mirror of https://github.com/yu-i-i/overleaf-cep.git synced 2026-05-29 12:01:32 +02:00
Code Issues Packages Projects Releases Wiki Activity

send health check to pubsub channel and use different var name

Browse Source
This commit is contained in:
Henry Oswald
2019-07-08 11:53:42 +01:00
parent eadef7b133
commit 1038c5cd0d
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
services/real-time/app.coffee
View File

@@ -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)