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

Compare commits

base: CITKParus:39fc3d14c7141072d4399511e2f0063cfeed85a4
Branches Tags
CITKParus:master
CITKParus:dependabot/npm_and_yarn/express-4.19.2
..
compare: CITKParus:67aafc25b7013bca48d29a434c479bbb61e5fabf
Branches Tags
CITKParus:master
CITKParus:dependabot/npm_and_yarn/express-4.19.2

No commits in common. "39fc3d14c7141072d4399511e2f0063cfeed85a4" and "67aafc25b7013bca48d29a434c479bbb61e5fabf" have entirely different histories.
39fc3d14c7 ... 67aafc25b7

1 changed files with 8 additions and 16 deletions
Show Stats Expand all files Collapse all files

24
core/out_queue_processor.js
View File

@ -621,25 +621,17 @@ const processTask = async prms => {
if (res instanceof ServerError) { if (res instanceof ServerError) {
throw res; throw res;
} else { } else {
//Нет ошибки, посмотрим что прилетело сообщение в успешном статусе и тогда по необходимости запустим обработку сервером БД //Если это не Kafka/MQTT сообщение - обрабатываем сервером БД
if (res.nExecState == objQueueSchema.NQUEUE_EXEC_STATE_APP_OK) { if (
//Если это не MQTT/MQTTS/Kafka - запустим обработку сервером БД, иначе установим статус успешного выполнения ![objServiceSchema.SPROTOCOL_KAFKA, objServiceSchema.SPROTOCOL_MQTT, objServiceSchema.SPROTOCOL_MQTTS].includes(
if ( getURLProtocol(prms.task.service.sSrvRoot)
![objServiceSchema.SPROTOCOL_KAFKA, objServiceSchema.SPROTOCOL_MQTT, objServiceSchema.SPROTOCOL_MQTTS].includes( )
getURLProtocol(prms.task.service.sSrvRoot) ) {
) //Нет ошибки, посмотрим что прилетело сообщение в успешном статусе и тогда запустим обработку сервером БД
) { if (res.nExecState == objQueueSchema.NQUEUE_EXEC_STATE_APP_OK) {
res = await dbProcess({ queue: res, function: prms.task.function }); res = await dbProcess({ queue: res, function: prms.task.function });
//Если результат обработки ошибка - пробрасываем её дальше //Если результат обработки ошибка - пробрасываем её дальше
if (res instanceof ServerError) throw res; if (res instanceof ServerError) throw res;
} else {
//Финализируем обработку
await dbConn.setQueueState({
nQueueId: q.nId,
sExecMsg: null,
nIncExecCnt: q.nExecCnt == 0 ? NINC_EXEC_CNT_YES : NINC_EXEC_CNT_NO,
nExecState: objQueueSchema.NQUEUE_EXEC_STATE_OK
});
} }
} }
} }