diff --git a/models/prms_out_queue.js b/models/prms_out_queue.js index b951f77..b97212a 100644 --- a/models/prms_out_queue.js +++ b/models/prms_out_queue.js @@ -48,6 +48,30 @@ exports.OutQueue = new Schema({ } }); +//Схема валидации параметров функции установки финальных статусов сообщения в БД +exports.finalise = new Schema({ + //Обрабатываемое исходящее сообщение + queue: { + schema: Queue, + required: true, + message: { + required: "Не указано обрабатываемое исходящее сообщение (queue)" + } + } +}); + +//Схема валидации параметров функции запуска обработчика БД +exports.dbProcess = new Schema({ + //Обрабатываемое исходящее сообщение + queue: { + schema: Queue, + required: true, + message: { + required: "Не указано обрабатываемое исходящее сообщение (queue)" + } + } +}); + //Схема валидации параметров функции передачи исходящего сообшения на обработку exports.processMessage = new Schema({ //Обрабатываемое исходящее сообщение