From 6960aab874e163419813e698d4afb3c664cf18d0 Mon Sep 17 00:00:00 2001 From: jaty Date: Fri, 16 Feb 2018 14:17:53 +0800 Subject: [PATCH 1/2] Default message for error encountered while establishing error is modified --- lib/worker.js | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/lib/worker.js b/lib/worker.js index 107592d..8c8ff93 100644 --- a/lib/worker.js +++ b/lib/worker.js @@ -75,6 +75,12 @@ FiveBeansWorker.prototype.start = function(tubes) this.client.on('error', function(err) { + if(!err.metadata){ + err.metadata = {}; + } + + err.metadata.fivebeans_error = 'beanstalkd connection error'; + self.emitWarning({message: 'beanstalkd connection error', error: err}); self.emit('error', err); }); From df201e95a88c49fcdae07d5e4b16a3040c67cad6 Mon Sep 17 00:00:00 2001 From: jaty Date: Thu, 15 Mar 2018 16:03:56 +0800 Subject: [PATCH 2/2] Added payload to information being emitted when a job is put in reserved --- lib/worker.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/worker.js b/lib/worker.js index 8c8ff93..beadb5f 100644 --- a/lib/worker.js +++ b/lib/worker.js @@ -155,7 +155,8 @@ FiveBeansWorker.prototype.doNext = function() } else { - self.emit('job.reserved', jobID); + try{ self.emit('job.reserved', jobID, payload.toString()); } + catch(e){ self.emit('job.reserved', jobID, 'unable to convert payload to string.'); } var job = null; try { job = JSON.parse(payload.toString()); }