From 31081877523242f8d6d33ff471a812119ff71922 Mon Sep 17 00:00:00 2001
From: soulgalore <peter@soulgalore.com>
Date: Mon, 6 Nov 2017 08:49:57 +0100
Subject: [PATCH] If we get an error on the queue make sure we exit with an
 error #1267

---
 lib/core/queueHandler.js | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/lib/core/queueHandler.js b/lib/core/queueHandler.js
index fa3a3033e2..90dca45d16 100644
--- a/lib/core/queueHandler.js
+++ b/lib/core/queueHandler.js
@@ -126,6 +126,10 @@ class QueueHandler {
         // FIXME handle rejections (i.e. failures while processing messages) properly
         queue.processingEnded(obj => {
           const message = obj.item;
+          // if we get a error message on the queue make sure we register that
+          if (message.type === 'error' || message.type.endsWith('.error')) {
+            this.errors.push(message.data);
+          }
           const err = obj.err;
           if (err) {
             let rejectionMessage =