smqp - npm Package Compare versions

Comparing version 9.0.4 to 9.0.5

dist/Queue.js

@@ -152,3 +152,3 @@ "use strict";
   })[0];
-  if (!message) return;
+  if (!message) return false;
   if (noAck) {
@@ -155,0 +155,0 @@ this._dequeueMessage(message);

package.json

 {
   "name": "smqp",
-  "version": "9.0.4",
+  "version": "9.0.5",
   "type": "module",
@@ -5,0 +5,0 @@ "description": "Synchronous message queueing package",

src/Queue.js

@@ -163,3 +163,3 @@ import { generateId, sortByPriority } from './shared.js';
   const message = this._consumeMessages(1, { noAck, consumerTag })[0];
-  if (!message) return;
+  if (!message) return false;
   if (noAck) {
@@ -166,0 +166,0 @@ this._dequeueMessage(message);

types/Broker.d.ts

@@ -52,3 +52,3 @@ import { ConsumeOptions } from './types.js';
   constructor(owner?: any);
-  owner: any;
+  owner?: any;
   get exchangeCount(): number;
@@ -115,3 +115,3 @@ get queueCount(): number;
     },
-  ): Message | undefined;
+  ): Message | boolean | undefined;
   ack(message: Message, allUpTo?: boolean): void;
@@ -118,0 +118,0 @@ ackAll(): void;

types/Queue.d.ts

@@ -59,3 +59,3 @@ import { ConsumeOptions, ExchangeEventEmitter } from './types.js';
   assertConsumer(onMessage: onMessage, consumeOptions?: ConsumeOptions, owner?: any): Consumer;
-  get(options?: ConsumeOptions): Message | undefined;
+  get(options?: ConsumeOptions): Message | boolean;
   ack(message: Message, allUpTo?: boolean): void;
@@ -62,0 +62,0 @@ nack(message: Message, allUpTo?: boolean, requeue?: boolean): void;

No alert changes

Improved metrics

Total package byte prevSize

126343

increased by0.02%

No dependency changes