diff --git a/lib/tasks/enqueue.js b/lib/tasks/enqueue.js index 7941a5a3..8174593e 100644 --- a/lib/tasks/enqueue.js +++ b/lib/tasks/enqueue.js @@ -65,7 +65,7 @@ class TaskEnqueue extends Task { super.kill(cs); this.killReason = reason || KillReason.Hangup; this.logger.info(`TaskEnqueue:kill ${this.queueName} with reason ${this.killReason}`); - this.emitter.emit('kill'); + this.emitter.emit('kill', reason || KillReason.Hangup); this.notifyTaskDone(); } @@ -239,7 +239,8 @@ class TaskEnqueue extends Task { ep.unbridge().catch((err) => {}); resolve(); }) - .on('kill', () => { + .on('kill', (reason) => { + this.killReason = reason; this.logger.info(`TaskEnqueue:_bridgeLocal ending with ${this.killReason}`); ep.unbridge().catch((err) => {}); @@ -277,7 +278,6 @@ class TaskEnqueue extends Task { const {lengthOfList} = cs.srf.locals.dbHelpers; const members = await lengthOfList(this.queueName); this.dequeued = true; - cs.performQueueWebhook({ event: 'leave', queue: this.data.name,