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

Считывние и передача обработчику исходящих списка сервисов

Browse Source
This commit is contained in:
Mikhail Chechnev 2018-12-01 22:26:28 +03:00
parent fbc71f5138
commit 5388c77ae1
1 changed files with 27 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
core/app.js
View File

@ -30,6 +30,8 @@ class ParusAppServer {
this.outQ = null; this.outQ = null;
//Флаг остановки сервера //Флаг остановки сервера
this.bStopping = false; this.bStopping = false;
//Список обслуживаемых сервисов
this.services = [];
//Привяжем методы к указателю на себя для использования в обработчиках событий //Привяжем методы к указателю на себя для использования в обработчиках событий
this.onDBConnected = this.onDBConnected.bind(this); this.onDBConnected = this.onDBConnected.bind(this);
this.onDBDisconnected = this.onDBDisconnected.bind(this); this.onDBDisconnected = this.onDBDisconnected.bind(this);
@ -42,6 +44,29 @@ class ParusAppServer {
this.logger.setDBConnector(this.dbConn, true); this.logger.setDBConnector(this.dbConn, true);
//Сообщим, что подключились к БД //Сообщим, что подключились к БД
await this.logger.info("Сервер приложений подключен к БД"); await this.logger.info("Сервер приложений подключен к БД");
//Считываем список сервисов
await this.logger.info("Запрашиваю информацию о сервисах...");
try {
this.services = await this.dbConn.getServices();
} catch (e) {
await this.logger.error("Ошибка получения списка сервисов: " + e.sCode + ": " + e.sMessage);
await this.stop();
return;
}
await this.logger.info("Список сервисов получен");
//Запускаем обслуживание очереди исходящих
await this.logger.info("Запуск обработчика очереди исходящих сообщений...");
try {
this.outQ.startProcessing(this.services);
} catch (e) {
await this.logger.error(
"Ошибка запуска обработчика очереди исходящих сообщений: " + e.sCode + ": " + e.sMessage
);
await this.stop();
return;
}
//Рапортуем, что запустились
await this.logger.info("Сервер приложений запущен");
} }
//При отключении от БД //При отключении от БД
async onDBDisconnected() { async onDBDisconnected() {
@ -67,7 +92,7 @@ class ParusAppServer {
await this.dbConn.disconnect(); await this.dbConn.disconnect();
process.exit(0); process.exit(0);
} catch (e) { } catch (e) {
await this.logger.error("Ошибка отключения от БД: " + e.sCODE + ": " + e.sMessage); await this.logger.error("Ошибка отключения от БД: " + e.sCode + ": " + e.sMessage);
process.exit(1); process.exit(1);
} }
} else { } else {
@ -89,7 +114,7 @@ class ParusAppServer {
//Создаём обработчик очереди исходящих //Создаём обработчик очереди исходящих
this.outQ = new oq.OutQueue({ outGoing: prms.config.outGoing, dbConn: this.dbConn, logger: this.logger }); this.outQ = new oq.OutQueue({ outGoing: prms.config.outGoing, dbConn: this.dbConn, logger: this.logger });
//Скажем что инициализировали //Скажем что инициализировали
await this.logger.info("Сервер приложение инициализирован"); await this.logger.info("Сервер приложений инициализирован");
} else { } else {
throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult); throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
} }
@ -111,11 +136,6 @@ class ParusAppServer {
//Подключаемся к БД //Подключаемся к БД
await this.logger.info("Подключение сервера приложений к БД..."); await this.logger.info("Подключение сервера приложений к БД...");
await this.dbConn.connect(); await this.dbConn.connect();
//Запускаем обслуживание очереди исходящих
await this.logger.info("Запуск обработчика очереди исходящих сообщений...");
this.outQ.startProcessing();
//Рапортуем, что запустились
await this.logger.info("Сервер приложений запущен");
} }
//Останов сервера //Останов сервера
async stop() { async stop() {