smqp - npm Package Compare versions

Comparing version 1.4.1 to 1.5.0

CHANGELOG.md

 Changelog
 =========
 
+# 1.5.0
+
+- Non-persistent message, message option `persistent = false`, will not be recovered when recovering from state
+
 # 1.4.1
@@ -5,0 +9,0 @@

dist/src/Queue.js

@@ -50,6 +50,6 @@ "use strict";
     queueMessage,
+    recover,
     reject,
-    unbindConsumer,
-    recover,
-    stop
+    stop,
+    unbindConsumer
   };
@@ -178,6 +178,8 @@ Object.defineProperty(queue, 'messageCount', {
   function get({
-    noAck
+    noAck,
+    consumerTag
   } = {}) {
     const message = consumeMessages(1, {
-      noAck
+      noAck,
+      consumerTag
     })[0];
@@ -374,2 +376,3 @@ if (!message) return;
     }) => {
+      if (properties.persistent === false) return;
       const msg = (0, _Message.Message)({ ...fields,
@@ -376,0 +379,0 @@ redelivered: true

package.json

 {
   "name": "smqp",
-  "version": "1.4.1",
+  "version": "1.5.0",
   "description": "Synchronous message queuing package",
@@ -5,0 +5,0 @@ "author": {

src/Queue.js

@@ -38,6 +38,6 @@ import {generateId, sortByPriority} from './shared';
     queueMessage,
+    recover,
     reject,
+    stop,
     unbindConsumer,
-    recover,
-    stop,
   };
@@ -177,4 +177,4 @@
 
-  function get({noAck} = {}) {
-    const message = consumeMessages(1, {noAck})[0];
+  function get({noAck, consumerTag} = {}) {
+    const message = consumeMessages(1, {noAck, consumerTag})[0];
     if (!message) return;
@@ -378,2 +378,3 @@ if (noAck) dequeue(message);
     state.messages.forEach(({fields, content, properties}) => {
+      if (properties.persistent === false) return;
       const msg = Message({...fields, redelivered: true}, content, properties, onMessageConsumed);
@@ -380,0 +381,0 @@ messages.push(msg);

No alert changes

Improved metrics

Total package byte prevSize

71672

increased by0.4%

Lines of code

2212

increased by0.18%

No dependency changes