reject messages with invalid typesrelease/2.17.0

1 files changed, 3 insertions, 0 deletions

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