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

Отдельный обработчик для ошибок отправки данных удалённому серверу

Browse Source
This commit is contained in:
Mikhail Chechnev 2019-02-05 18:20:46 +03:00
parent e246ce117e
commit 4c1a787b12
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
core/out_queue_processor.js
View File

@ -24,6 +24,7 @@ const {
SERR_APP_SERVER_BEFORE,
SERR_APP_SERVER_AFTER,
SERR_DB_SERVER,
SERR_WEB_SERVER,
SERR_UNAUTH
} = require("./constants"); //Глобальные константы
const {
@ -205,14 +206,20 @@ const appProcess = async prms => {
nQueueId: prms.queue.nId
});
//Отправляем сообщение удалённому серверу
let serverResp = await rqp(options);
//Сохраняем полученный ответ
prms.queue.blResp = new Buffer(serverResp);
await dbConn.setQueueResp({
nQueueId: prms.queue.nId,
blResp: prms.queue.blResp,
nIsOriginal: NIS_ORIGINAL_YES
});
try {
//Ждем ответ от удалённого сервера
let serverResp = await rqp(options);
//Сохраняем полученный ответ
prms.queue.blResp = new Buffer(serverResp || "");
await dbConn.setQueueResp({
nQueueId: prms.queue.nId,
blResp: prms.queue.blResp,
nIsOriginal: NIS_ORIGINAL_YES
});
} catch (e) {
//Прекращаем исполнение если были ошибки
throw new ServerError(SERR_WEB_SERVER, `${e.response.statusCode} - ${e.response.statusMessage}`);
}
//Выполняем обработчик "После" (если он есть)
if (prms.function.sAppSrvAfter) {
const fnAfter = getAppSrvFunction(prms.function.sAppSrvAfter);