fix: allow empty payloads (#942)

pagerinc · Nov 7, 2022 · af1e3ae · af1e3ae
1 parent 68642b9
commit af1e3ae
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 3 deletions.
diff --git a/lib/queue.js b/lib/queue.js
@@ -32,9 +32,6 @@ const queue = (options) => {
         const onMessage = (msg) => {
 
             const data = parseMessage(msg);
-            if (!data) {
-                return;
-            }
 
             const ack = (reply) => {
 

diff --git a/test/queue.test.js b/test/queue.test.js
@@ -101,6 +101,19 @@ describe('queue', () => {
                 exchange.publish(message, { key: name });
             });
         });
+
+        it('consumes empty payloads', (done) => {
+
+            queue.consume((data) => {
+
+                Assert.equal(data, null);
+                done();
+            });
+            queue.on('ready', () => {
+
+                exchange.publish(null, { key: name });
+            });
+        });
     });
 
     describe('cancel', () => {