@pager/jackrabbit - npm Package Compare versions

Comparing version 4.8.0 to 4.8.1

lib/queue.js

		@@ -30,14 +30,2 @@ 'use strict';

		if ( ready ){
		const opts = Extend({}, DEFAULT_CONSUME_OPTIONS, consumeOptions);
		channel.consume(emitter.name, onMessage, opts, onConsume);
		}
		else {
		emitter.once('ready', () => {

		const opts = Extend({}, DEFAULT_CONSUME_OPTIONS, consumeOptions);
		channel.consume(emitter.name, onMessage, opts, onConsume);
		});
		}

		const onMessage = (msg) => {
		@@ -75,2 +63,16 @@
		};

		if ( ready ){

		const opts = Extend({}, DEFAULT_CONSUME_OPTIONS, consumeOptions);
		channel.consume(emitter.name, onMessage, opts, onConsume);
		return;
		}


		emitter.once('ready', () => {

		const opts = Extend({}, DEFAULT_CONSUME_OPTIONS, consumeOptions);
		channel.consume(emitter.name, onMessage, opts, onConsume);
		});
		};
		@@ -77,0 +79,0 @@

package.json

		{
		"name": "@pager/jackrabbit",
		"version": "4.8.0",
		"version": "4.8.1",
		"description": "Easy RabbitMQ for node",
		@@ -5,0 +5,0 @@ "keywords": [

New alerts