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-01-02 01:50:57 +03:00
parent 508f476d3e
commit d92d85f4f6
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/out_queue_processor.js
View File

@ -163,6 +163,10 @@ const appProcess = async prms => {
} }
} }
} }
//Фиксируем отправку сообщения в протоколе работы сервиса
await logger.info(`Отправляю исходящее сообщение ${prms.queue.nId} на URL: ${options.url}`, {
nQueueId: prms.queue.nId
});
//Отправляем сообщение удалённому серверу //Отправляем сообщение удалённому серверу
let serverResp = await rqp(options); let serverResp = await rqp(options);
//Сохраняем полученный ответ //Сохраняем полученный ответ
@ -327,6 +331,8 @@ const processTask = async prms => {
await dbConn.connect(); await dbConn.connect();
//Считываем запись очереди //Считываем запись очереди
q = await dbConn.getQueue({ nQueueId: prms.task.nQueueId }); q = await dbConn.getQueue({ nQueueId: prms.task.nQueueId });
//!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! Проверяем аутентификацию
//if(prms.task.function.)
//Далее работаем от статуса считанной записи //Далее работаем от статуса считанной записи
switch (q.nExecState) { switch (q.nExecState) {
//Поставлено в очередь //Поставлено в очередь