servicebus
Advanced tools
Comparing version
@@ -19,3 +19,2 @@ var amqp = require('amqp'), | ||
this.log = options.log || log; | ||
this.namespace = options.namespace || process.env.SERVICEBUS_NAMESPACE || ''; | ||
this.pubsubqueues = {}; | ||
@@ -62,4 +61,2 @@ this.queues = {}; | ||
queueName = this.namespace + queueName; | ||
if (self.queues[queueName] === undefined) { | ||
@@ -86,4 +83,2 @@ log('creating queue ' + queueName); | ||
queueName = this.namespace + queueName; | ||
if (self.queues[queueName] === undefined) { | ||
@@ -124,4 +119,2 @@ self.queues[queueName] = new Queue({ bus: self, connection: self.connection, queueName: queueName, log: self.log }); | ||
queueName = this.namespace + queueName; | ||
if (self.pubsubqueues[queueName] === undefined) { | ||
@@ -145,4 +138,2 @@ self.pubsubqueues[queueName] = new PubSubQueue({ bus: self, connection: self.connection, queueName: queueName, log: self.log }); | ||
if (self.initialized) { | ||
queueName = this.namespace + queueName; | ||
@@ -149,0 +140,0 @@ if (self.pubsubqueues[queueName] === undefined) { |
@@ -45,2 +45,4 @@ var Correlator = require('./correlator'), | ||
if (options && options.ack) { | ||
queueOptions.durable = true; | ||
queueOptions.autoDelete = false; | ||
self.connection.queue(self.errorQueueName, queueOptions, function (q) { | ||
@@ -47,0 +49,0 @@ q.bind(self.exchange, self.errorQueueName); |
@@ -31,2 +31,4 @@ var events = require('events'), | ||
if (options && options.ack) { | ||
queueOptions.durable = true; | ||
queueOptions.autoDelete = false; | ||
self.connection.queue(self.queueName + '.error', queueOptions, function(eq) { | ||
@@ -33,0 +35,0 @@ eq.bind(self.errorQueueName); |
@@ -9,3 +9,3 @@ { | ||
"description": "Simple service bus for sending events between processes using amqp.", | ||
"version": "0.2.2", | ||
"version": "0.2.3", | ||
"homepage": "https://github.com/mateodelnorte/servicebus", | ||
@@ -12,0 +12,0 @@ "repository": { |
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 1 instance in 1 package
5
-37.5%33519
-5.92%27
-3.57%773
-5.04%