Dollerok/P8-ExchangeService
1
0
Fork 0
forked from CITKParus/P8-ExchangeService
Code Issues Pull Requests Projects Releases Wiki Activity

Отложенный запуск обработки очереди

Browse Source
This commit is contained in:
Mikhail Chechnev 2018-11-20 17:23:43 +03:00
parent df3b9eb5bf
commit 3f665e7ed4
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
core/out_queue.js
View File

@ -44,6 +44,8 @@ class OutQueue extends EventEmitter {
this.dbConn = dbConn; this.dbConn = dbConn;
//Запомним логгер //Запомним логгер
this.logger = logger; this.logger = logger;
//Привяжем методы к указателю на себя для использования в обработчиках событий
this.outDetectingLoop = this.outDetectingLoop.bind(this);
} else { } else {
throw new ServerError( throw new ServerError(
glConst.SERR_OBJECT_BAD_INTERFACE, glConst.SERR_OBJECT_BAD_INTERFACE,
@ -91,14 +93,14 @@ class OutQueue extends EventEmitter {
async startProcessing() { async startProcessing() {
await this.logger.info("Запуск обработчика очереди исходящих сообщений..."); await this.logger.info("Запуск обработчика очереди исходящих сообщений...");
this.bWorking = true; this.bWorking = true;
this.outDetectingLoop(); setTimeout(this.outDetectingLoop, 3000);
await this.logger.info("Обработчик очереди исходящих сообщений запущен"); await this.logger.info("Обработчик очереди исходящих сообщений запущен");
} }
//Остановка обработки очереди печати //Остановка обработки очереди печати
async stopProcessing() { async stopProcessing() {
await this.logger.info("Останов обработчика очереди исходящих сообщений..."); await this.logger.warn("Останов обработчика очереди исходящих сообщений...");
this.bWorking = false; this.bWorking = false;
await this.logger.info("Обработчик очереди исходящих сообщений остановлен"); await this.logger.warn("Обработчик очереди исходящих сообщений остановлен");
} }
} }