smqp - npm Package Compare versions

Comparing version 0.3.0 to 0.4.0

dist/index.js

@@ -455,5 +455,8 @@ 'use strict';
     options = Object.assign({ autoDelete: true }, options);
+    const { deadLetterExchange } = options;
+    if (deadLetterExchange) assertExchange(deadLetterExchange);
 
     const queue = {
       name: queueName,
+      deadLetterExchange,
       options,
@@ -584,4 +587,10 @@ addConsumer,
       switch (operation) {
+        case 'reject':
         case 'nack':
-          if (!requeue) dequeue(message);
+          if (requeue) break;
+
+          dequeue(message);
+          if (deadLetterExchange) {
+            publish(deadLetterExchange, message.routingKey, message.content);
+          }
           break;
@@ -588,0 +597,0 @@ default:

index.js

@@ -451,5 +451,8 @@ export function Broker(source) {
     options = Object.assign({autoDelete: true}, options);
+    const {deadLetterExchange} = options;
+    if (deadLetterExchange) assertExchange(deadLetterExchange);
 
     const queue = {
       name: queueName,
+      deadLetterExchange,
       options,
@@ -580,4 +583,10 @@ addConsumer,
       switch (operation) {
+        case 'reject':
         case 'nack':
-          if (!requeue) dequeue(message);
+          if (requeue) break;
+
+          dequeue(message);
+          if (deadLetterExchange) {
+            publish(deadLetterExchange, message.routingKey, message.content);
+          }
           break;
@@ -584,0 +593,0 @@ default:

package.json

 {
   "name": "smqp",
-  "version": "0.3.0",
+  "version": "0.4.0",
   "description": "Synchronous message queuing package",
@@ -32,5 +32,6 @@ "author": {
   "scripts": {
-    "test": "mocha && npm run dist &&  eslint . --cache",
+    "test": "mocha && npm run dist &&  eslint . --cache && npm run toc",
     "dist": "babel index.js -d dist",
-    "prepare": "npm run dist"
+    "prepare": "npm run dist",
+    "toc": "node ./scripts/generate-api-toc.js"
   },
@@ -53,4 +54,5 @@ "keywords": [
     "eslint": "^4.19.1",
+    "markdown-toc": "^1.2.0",
     "mocha": "^5.2.0"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

47368

increased by1.48%

Lines of code

1391

increased by1.16%

Worsened metrics

Dev dependency count

6

increased by20%

No dependency changes