From 329d168215a66e4a646ee9ab6d05e09e55b9f2ae Mon Sep 17 00:00:00 2001 From: Mikhail Chechnev Date: Tue, 27 Oct 2020 00:39:23 +0300 Subject: [PATCH] =?UTF-8?q?=D0=9E=D0=B1=D1=80=D0=B0=D0=B1=D0=BE=D1=82?= =?UTF-8?q?=D0=BA=D0=B0=20=D0=B2=D1=85=D0=BE=D0=B4=D1=8F=D1=89=D0=B8=D1=85?= =?UTF-8?q?=20-=20=D0=BF=D0=B5=D1=80=D0=B5=D0=B4=D0=B0=D1=87=D0=B0=20"noti?= =?UTF-8?q?fier"=20=D0=B8=20"dbConn"=20=D0=B2=20=D0=BF=D0=BE=D1=81=D1=82?= =?UTF-8?q?=D0=BE=D0=B1=D1=80=D0=B0=D0=B1=D0=BE=D1=82=D1=87=D0=B8=D0=BA,?= =?UTF-8?q?=20=D0=BF=D0=B5=D1=80=D0=B5=D0=B4=D0=B0=D1=87=D0=B0=20"notifier?= =?UTF-8?q?"=20=D0=B2=20=D0=BF=D1=80=D0=B5=D0=B4=D0=BE=D0=B1=D1=80=D0=B0?= =?UTF-8?q?=D0=B1=D0=BE=D1=82=D1=87=D0=B8=D0=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- core/in_queue.js | 3 +++ 1 file changed, 3 insertions(+) diff --git a/core/in_queue.js b/core/in_queue.js index f9e8a0e..a89b9b0 100644 --- a/core/in_queue.js +++ b/core/in_queue.js @@ -157,6 +157,7 @@ class InQueue extends EventEmitter { resBeforePrms.queue.blResp = blResp; resBeforePrms.options = _.cloneDeep(options); resBeforePrms.dbConn = this.dbConn; + resBeforePrms.notifier = this.notifier; resBeforePrms.res = prms.res; resBefore = await fnBefore(resBeforePrms); } catch (e) { @@ -267,6 +268,8 @@ class InQueue extends EventEmitter { resAfterPrms.queue.blResp = blResp; resAfterPrms.options = _.cloneDeep(options); resAfterPrms.optionsResp = _.cloneDeep(optionsResp); + resAfterPrms.dbConn = this.dbConn; + resAfterPrms.notifier = this.notifier; resAfter = await fnAfter(resAfterPrms); } catch (e) { throw new ServerError(SERR_APP_SERVER_AFTER, e.message);