diff --git a/services/real-time/app.js b/services/real-time/app.js index 47cae86f45..b34b33df61 100644 --- a/services/real-time/app.js +++ b/services/real-time/app.js @@ -9,7 +9,6 @@ const Metrics = require('metrics-sharelatex') const Settings = require('settings-sharelatex') Metrics.initialize(Settings.appName || 'real-time') const async = require('async') -const _ = require('underscore') const logger = require('logger-sharelatex') logger.initialize('real-time') @@ -214,7 +213,7 @@ if (Settings.shutdownDrainTimeWindow != null) { } if (Settings.continualPubsubTraffic) { - console.log('continualPubsubTraffic enabled') + logger.warn('continualPubsubTraffic enabled') const pubsubClient = redis.createClient(Settings.redis.pubsub) const clusterClient = redis.createClient(Settings.redis.websessions) @@ -239,7 +238,7 @@ if (Settings.continualPubsubTraffic) { } var runPubSubTraffic = () => - async.map(['applied-ops', 'editor-events'], publishJob, (err) => + async.map(['applied-ops', 'editor-events'], publishJob, () => setTimeout(runPubSubTraffic, 1000 * 20) )