forked from CITKParus/P8-ExchangeService
Тихое и асинхронное добавление сообщения в очередь уведомлений
This commit is contained in:
parent
7b44cfbe2b
commit
6fb79a34ee
@ -63,7 +63,7 @@ class Notifier extends EventEmitter {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
//Добавление уведомления в очередь отправки
|
//Добавление уведомления в очередь отправки
|
||||||
addMessage(prms) {
|
async addMessage(prms) {
|
||||||
//Проверяем структуру переданного объекта для старта
|
//Проверяем структуру переданного объекта для старта
|
||||||
let sCheckResult = validateObject(
|
let sCheckResult = validateObject(
|
||||||
prms,
|
prms,
|
||||||
@ -76,7 +76,11 @@ class Notifier extends EventEmitter {
|
|||||||
tmp.bSent = false;
|
tmp.bSent = false;
|
||||||
this.messages.push(tmp);
|
this.messages.push(tmp);
|
||||||
} else {
|
} else {
|
||||||
throw new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult);
|
await this.logger.error(
|
||||||
|
`Ошибка добавления уведомления в очередь: ${makeErrorText(
|
||||||
|
new ServerError(SERR_OBJECT_BAD_INTERFACE, sCheckResult)
|
||||||
|
)}`
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
//Уведомление о запуске модуля
|
//Уведомление о запуске модуля
|
||||||
|
Loading…
x
Reference in New Issue
Block a user