forked from CITKParus/P8-ExchangeService
ЦИТК-1018 - Фиксация в очереди идентификатора сервера интеграции, обработавшего входящее сообщение
Reviewed-on: CITKParus/P8-ExchangeService#14
This commit is contained in:
commit
3dcba310f6
@ -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);
|
||||
|
||||
@ -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,
|
||||
|
||||
@ -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,
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user