@emartech/rabbitmq-client - npm Package Compare versions

Comparing version 3.4.0 to 3.5.0

package.json

@@ -39,3 +39,3 @@ {
   },
-  "version": "3.4.0"
+  "version": "3.5.0"
 }

src/consumers/consumer-dlx-retry.js

@@ -20,3 +20,3 @@ 'use strict';
       deadLetterExchange: '',
-      deadLetterRoutingKey: `${configuration.channel}-retry`
+      deadLetterRoutingKey: `${configuration.channel}-retry-${this._retryTime}`
     };
@@ -31,3 +31,3 @@ this._amqpConfig = amqpConfig;
     try {
-      await RabbitMq.create(this._amqpConfig, `${this._channel}-retry`, this._connectionType, {
+      await RabbitMq.create(this._amqpConfig, `${this._channel}-retry-${this._retryTime}`, this._connectionType, {
         messageTtl: this._retryTime,
@@ -34,0 +34,0 @@ deadLetterExchange: '',

src/consumers/consumer-dlx-retry.spec.js

@@ -27,3 +27,3 @@ 'use strict';
 
-describe.only('RabbitMQ Consumer with DLX Retry', function () {
+describe('RabbitMQ Consumer with DLX Retry', function () {
   let sandbox = sinon.createSandbox();
@@ -99,3 +99,3 @@ let clock;
       deadLetterExchange: '',
-      deadLetterRoutingKey: `${channelName}-retry`
+      deadLetterRoutingKey: `${channelName}-retry-60000`
     });
@@ -117,3 +117,3 @@ });
 
-    expect(rabbitMqStub).have.been.calledWith(amqpConfig, `${channelName}-retry`, 'default', {
+    expect(rabbitMqStub).have.been.calledWith(amqpConfig, `${channelName}-retry-300`, 'default', {
       messageTtl: 300,
@@ -120,0 +120,0 @@ deadLetterExchange: '',

No alert changes

Improved metrics

Total package byte prevSize

49068

increased by0.09%

No dependency changes