servicebus - npm Package Compare versions

Comparing version 1.0.9 to 1.0.10

bus/rabbitmq/correlator.js

		@@ -44,4 +44,2 @@ var cluster = require('cluster');

		var routingKey = options.queueName;

		if ( ! this.initialized) {
		@@ -53,9 +51,11 @@ return this.on('ready', queueName.bind(this, options, callback));

		if (this.queues.hasOwnProperty(routingKey)) {
		result = this.queues[routingKey];
		} else if (options.subscriptionName) {
		result = options.subscriptionName;
		if (this.queues.hasOwnProperty(options.queueName)) {
		result = this.queues[options.queueName];
		} else if (options.queueName) {
		result = options.queueName;
		} else if (options.routingKey) {
		result = options.routingKey;
		} else {
		result = util.format('%s.%s', routingKey, newId());
		this.queues[routingKey] = result;
		result = util.format('%s.%s', options.queueName, newId());
		this.queues[options.queueName] = result;
		}
		@@ -62,0 +62,0 @@

package.json

		@@ -10,3 +10,3 @@ {
		"description": "Simple service bus for sending events between processes using amqp.",
		"version": "1.0.9",
		"version": "1.0.10",
		"homepage": "https://github.com/mateodelnorte/servicebus",
		@@ -13,0 +13,0 @@ "repository": {

New alerts