@thecolvinco/nodejs-amqplib - npm Package Compare versions

Comparing version 0.0.8 to 0.0.9

dist/main.esm.js

@@ -66,3 +66,4 @@ import { connect } from 'amqplib';
   maxRetries = 5,
-  delay = 5000
+  delay = 5000,
+  onRejected
 }) {
@@ -96,2 +97,3 @@ try {
       } else {
+        if (typeof onRejected === 'function') onRejected(message);
         channel.nack(message, false, false);
@@ -98,0 +100,0 @@ }

dist/main.js

@@ -66,3 +66,4 @@ var amqplib = require('amqplib');
   maxRetries = 5,
-  delay = 5000
+  delay = 5000,
+  onRejected
 }) {
@@ -96,2 +97,3 @@ try {
       } else {
+        if (typeof onRejected === 'function') onRejected(message);
         channel.nack(message, false, false);
@@ -98,0 +100,0 @@ }

dist/main.modern.js

@@ -28,3 +28,4 @@ import { connect } from 'amqplib';
   maxRetries: _maxRetries = 5,
-  delay: _delay = 5000
+  delay: _delay = 5000,
+  onRejected
 }) => {
@@ -52,2 +53,3 @@ const {
   } else {
+    if (typeof onRejected === 'function') onRejected(message);
     channel.nack(message, false, false);
@@ -54,0 +56,0 @@ }

dist/main.umd.js

@@ -69,3 +69,4 @@ (function (global, factory) {
     maxRetries = 5,
-    delay = 5000
+    delay = 5000,
+    onRejected
   }) {
@@ -99,2 +100,3 @@ try {
         } else {
+          if (typeof onRejected === 'function') onRejected(message);
           channel.nack(message, false, false);
@@ -101,0 +103,0 @@ }

dist/utils/retryable.d.ts

 import { retryable } from '../types';
-declare const _default: ({ channel, message, queue, retryExchange, maxRetries, delay, }: retryable) => Promise<void>;
+declare const _default: ({ channel, message, queue, retryExchange, maxRetries, delay, onRejected, }: retryable) => Promise<void>;
 export default _default;

package.json

 {
   "name": "@thecolvinco/nodejs-amqplib",
   "description": "RabbitMQ abstraction with some utils",
-  "version": "0.0.8",
+  "version": "0.0.9",
   "source": "src/main.ts",
@@ -6,0 +6,0 @@ "main": "dist/main.umd.js",

No alert changes

Improved metrics

Total package byte prevSize

73546

increased by1.43%

Lines of code

899

increased by0.9%

No dependency changes