fix(message): return message on queue pull mode transport

lykmapipo · Feb 29, 2020 · 2b671d7 · 2b671d7
1 parent f54194f
commit 2b671d7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/message.model.js b/lib/message.model.js
@@ -917,7 +917,7 @@ MessageSchema.methods.queue = function queue(done) {
     //for actul send
     else if (message.mode === SEND_MODE_PULL) {
       worker.queue.emit('job queued', message);
-      return;
+      return cb(null, message);
     }
 
     //queue message for later send