ЦИТК-1018 - Фиксация в очереди идентификатора сервера интеграции, обработавшего входящее сообщение

Reviewed-on: #14

core/db_connector.js

@@ -521,6 +521,7 @@ class DBConnector extends EventEmitter {
                 let putQueueData = _.cloneDeep(prms);
                 putQueueData.blMsg = prms.blMsg ? prms.blMsg : Buffer.from("");
                 putQueueData.connection = this.connection;
+                putQueueData.nExsSrv = this.nExsSrv;
                 //Исполняем действие в БД
                 try {
                     let res = await this.connector.putQueue(putQueueData);

modules/parus_oracle_db.js

@@ -373,6 +373,7 @@ const putQueue = async prms => {
         inPrms: {
             NEXSSERVICEFN: prms.nServiceFnId,
             BMSG: prms.blMsg,
+            NEXSSRV: prms.nExsSrv,
             NEXSQUEUE: prms.nQueueId,
             NLNK_COMPANY: prms.nLnkCompanyId,
             NLNK_DOCUMENT: prms.nLnkDocumentId,

modules/parus_pg_db.js

@@ -361,6 +361,7 @@ const putQueue = async prms => {
         inPrms: {
             NEXSSERVICEFN: prms.nServiceFnId,
             BMSG: prms.blMsg,
+            NEXSSRV: prms.nExsSrv,
             NEXSQUEUE: prms.nQueueId,
             NLNK_COMPANY: prms.nLnkCompanyId,
             NLNK_DOCUMENT: prms.nLnkDocumentId,