New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

servicebus

Package Overview
Dependencies
Maintainers
2
Versions
73
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

servicebus - npm Package Compare versions

Comparing version

to
0.2.3

9

bus/rabbitmq/bus.js

@@ -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) {

2

bus/rabbitmq/pubsubqueue.js

@@ -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": {