smqp - npm Package Compare versions

Comparing version 2.0.0 to 2.0.1

CHANGELOG.md

 Changelog
 =========
 
+# 2.0.1
+- Support passing source binding priority to shovel or bound exchange
+
 # 2.0.0
@@ -5,0 +8,0 @@

dist/src/Broker.js

@@ -256,2 +256,5 @@ "use strict";
     const {
+      priority
+    } = args;
+    const {
       consumerTag,
@@ -265,2 +268,3 @@ on: onShovel,
       pattern,
+      priority,
       consumerTag: `smq.ctag-${name}`
@@ -267,0 +271,0 @@ }, {

dist/src/Shovel.js

@@ -15,3 +15,4 @@ "use strict";
     pattern,
-    queue
+    queue,
+    priority
   } = source;
@@ -62,7 +63,9 @@ const {
     consumer = sourceBroker.subscribe(sourceExchangeName, routingKeyPattern, queue, onShovelMessage, {
-      consumerTag
+      consumerTag,
+      priority
     });
   } else {
     consumer = sourceBroker.subscribeTmp(sourceExchangeName, routingKeyPattern, onShovelMessage, {
-      consumerTag
+      consumerTag,
+      priority
     });
@@ -69,0 +72,0 @@ api.source.queue = consumer.queue.name;

package.json

 {
   "name": "smqp",
-  "version": "2.0.0",
+  "version": "2.0.1",
   "description": "Synchronous message queuing package",
@@ -59,9 +59,9 @@ "author": {
   "devDependencies": {
-    "@babel/cli": "^7.7.0",
-    "@babel/core": "^7.7.2",
-    "@babel/preset-env": "^7.7.1",
-    "@babel/register": "^7.7.0",
+    "@babel/cli": "^7.7.4",
+    "@babel/core": "^7.7.4",
+    "@babel/preset-env": "^7.7.4",
+    "@babel/register": "^7.7.4",
     "chai": "^4.2.0",
     "chronokinesis": "^2.0.1",
-    "eslint": "^6.6.0",
+    "eslint": "^6.7.0",
     "markdown-toc": "^1.2.0",
@@ -68,0 +68,0 @@ "mocha": "^6.2.2",

src/Broker.js

@@ -240,2 +240,3 @@ import {Exchange, EventExchange} from './Exchange';
     const name = `e2e-${source}2${destination}-${pattern}`;
+    const {priority} = args;
     const {consumerTag, on: onShovel, close: onClose, source: shovelSource} = createShovel(name, {
@@ -245,2 +246,3 @@ broker,
       pattern,
+      priority,
       consumerTag: `smq.ctag-${name}`,
@@ -247,0 +249,0 @@ }, {

src/Shovel.js

 import {EventExchange} from './Exchange';
 
 export function Shovel(name, source, destination, options = {}) {
-  const {broker: sourceBroker, exchange: sourceExchangeName, pattern, queue} = source;
+  const {broker: sourceBroker, exchange: sourceExchangeName, pattern, queue, priority} = source;
   const {broker: destinationBroker, exchange: destinationExchangeName} = destination;
@@ -45,5 +45,5 @@ const {cloneMessage} = options;
   if (queue) {
-    consumer = sourceBroker.subscribe(sourceExchangeName, routingKeyPattern, queue, onShovelMessage, {consumerTag});
+    consumer = sourceBroker.subscribe(sourceExchangeName, routingKeyPattern, queue, onShovelMessage, {consumerTag, priority});
   } else {
-    consumer = sourceBroker.subscribeTmp(sourceExchangeName, routingKeyPattern, onShovelMessage, {consumerTag});
+    consumer = sourceBroker.subscribeTmp(sourceExchangeName, routingKeyPattern, onShovelMessage, {consumerTag, priority});
     api.source.queue = consumer.queue.name;
@@ -50,0 +50,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

85929

increased by0.3%

Lines of code

2658

increased by0.34%

No dependency changes