diff options
author | Evgeny Zinoviev <me@ch1p.io> | 2021-03-01 02:05:37 +0300 |
---|---|---|
committer | Evgeny Zinoviev <me@ch1p.io> | 2021-03-01 02:05:37 +0300 |
commit | 8783de4fe5945a7ea22995c25a3e546c0426c7f6 (patch) | |
tree | 17711b548483b57a5b5b2b81594ad2a19fc6eeab /src/lib/workers-list.js | |
parent | 57f541a6ea6722a2902e7cc7774aefca883fe8de (diff) |
update protocol
Diffstat (limited to 'src/lib/workers-list.js')
-rw-r--r-- | src/lib/workers-list.js | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/lib/workers-list.js b/src/lib/workers-list.js index 620f711..ed436e0 100644 --- a/src/lib/workers-list.js +++ b/src/lib/workers-list.js @@ -1,7 +1,7 @@ const intersection = require('lodash/intersection') const config = require('./config') const {getLogger} = require('./logger') -const {RequestMessage} = require('./server') +const {RequestMessage, PingMessage} = require('./server') const throttle = require('lodash/throttle') class WorkersList { @@ -136,7 +136,7 @@ class WorkersList { this.workers .forEach(w => { this.logger.trace(`sending ping to ${w.connection.remoteAddr()}`) - w.connection.send(new RequestMessage('ping')) + w.connection.send(new PingMessage()) }) } |