diff --git a/lib/request.js b/lib/request.js index da13357..055daab 100644 --- a/lib/request.js +++ b/lib/request.js @@ -2,6 +2,7 @@ // SPDX-License-Identifier: MIT const Policy = require('./traversalPolicy'); +const _ = require('lodash'); /** * Requests describe a resource to capture and process as well as the context for that processing. @@ -201,7 +202,7 @@ class Request { if (pruneRelation) { delete newRequest.context.relation; } - this.queueRequests(newRequest); + this.queueRequests(newRequest, _.get(this._originQueue, 'queue.name')); } markDead(outcome, message) { @@ -308,4 +309,4 @@ class Request { } } -module.exports = Request; \ No newline at end of file +module.exports = Request;