rabbitmq-pub-sub - npm Package Compare versions

Comparing version 0.2.3 to 0.2.4

dist/main.js

@@ -466,3 +466,3 @@ module.exports =
                         result = _a.sent();
-                        this.logger.debug("get amq result", result);
+                        this.logger.debug("queue genereted for subscription is '(%j)') ", result);
                         this.dynamicQueueName = result.queue;
@@ -479,3 +479,3 @@ return [4 /*yield*/, channel.bindQueue(this.dynamicQueueName, queueConfig.dlx, '')];
         return {
-            exclusive: true
+            exclusive: false
         };
@@ -482,0 +482,0 @@ };

package.json

 {
   "name": "rabbitmq-pub-sub",
-  "version": "0.2.3",
+  "version": "0.2.4",
   "description": "RabbitMq Producer and Consumer",
@@ -5,0 +5,0 @@ "main": "./dist/main.js",

src/subscriber.ts

@@ -67,3 +67,3 @@ import * as amqp from "amqplib";
            let result =  await channel.assertQueue(queueConfig.dlq, this.getQueueSettings(queueConfig.dlx));
-           this.logger.debug("get amq result", result);
+           this.logger.debug("queue genereted for subscription is '(%j)') ", result);
            this.dynamicQueueName = result.queue;
@@ -75,3 +75,3 @@ await channel.bindQueue(this.dynamicQueueName, queueConfig.dlx, '');
         return {
-            exclusive: true
+            exclusive: false
         }
@@ -78,0 +78,0 @@ }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

92286

increased by0.1%

No dependency changes