From 37e55570ad1f8c4f9cf53930c53312b4132f51d1 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Sun, 24 Sep 2017 20:52:57 +0200
Subject: reject messages with invalid types

---
 worker.js | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/worker.js b/worker.js
index d3292ba..50c8db3 100644
--- a/worker.js
+++ b/worker.js
@@ -207,6 +207,9 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
                     msg_buffer.add(msg);
                 }
                 break;
+            default:
+                logger.error("invalid message", msg);
+                await ch.nack(msg, false, false);
         }
 
         // fill queue until batchsize or idle
-- 
cgit v1.3.1