@bss-sbc/rabbitmq-connection-instance - npm Package Compare versions

Comparing version 1.0.5 to 1.0.6

dist/rabbitmq.d.ts

		@@ -12,3 +12,3 @@ /// <reference types="node" />
		connect(uri: string, options?: Options): Promise<NodeJS.Timeout \| undefined>;
		publish(queue: string, exchange: string, type: string, routingKey: string, data: any): Promise<boolean \| undefined>;
		publish(queue: string, exchange: string, type: string, routingKey: string, bindingKey: string, data: any): Promise<boolean \| undefined>;
		consume(queue: string, onMessage: OnMessage): Promise<Replies.Consume \| undefined>;
		@@ -27,3 +27,3 @@ stopConsume(queue: string): Promise<void>;
		connect(uri: string, options?: Options): Promise<NodeJS.Timeout \| undefined>;
		publish(queue: string, exchange: string, type: string, routingKey: string, data: any): Promise<boolean \| undefined>;
		publish(queue: string, exchange: string, type: string, routingKey: string, bindingKey: string, data: any): Promise<boolean \| undefined>;
		consume(queue: string, onMessage: OnMessage): Promise<Replies.Consume \| undefined>;
		@@ -30,0 +30,0 @@ stopConsume(queue: string): Promise<void>;

dist/rabbitmq.js

		@@ -47,3 +47,3 @@ "use strict";
		}
		async publish(queue, exchange, type, routingKey, data) {
		async publish(queue, exchange, type, routingKey, bindingKey, data) {
		let result;
		@@ -53,3 +53,3 @@ if (!!this.publisher) {
		await this.publisher.assertQueue(queue);
		await this.publisher.bindQueue(queue, exchange, routingKey);
		await this.publisher.bindQueue(queue, exchange, bindingKey);
		// TODO: Logger published
		@@ -56,0 +56,0 @@ result = this.publisher.publish(exchange, routingKey, Buffer.from(JSON.stringify(data)));

package.json

		{
		"name": "@bss-sbc/rabbitmq-connection-instance",
		"version": "1.0.5",
		"version": "1.0.6",
		"description": "",
		@@ -5,0 +5,0 @@ "main": "dist/rabbitmq.js",

		@@ -12,3 +12,3 @@ /// <reference types="node" />
		connect(uri: string, options?: Options): Promise<NodeJS.Timeout \| undefined>;
		publish(queue: string, exchange: string, type: string, routingKey: string, data: any): Promise<boolean \| undefined>;
		publish(queue: string, exchange: string, type: string, routingKey: string, bindingKey: string, data: any): Promise<boolean \| undefined>;
		consume(queue: string, onMessage: OnMessage): Promise<Replies.Consume \| undefined>;
		@@ -27,3 +27,3 @@ stopConsume(queue: string): Promise<void>;
		connect(uri: string, options?: Options): Promise<NodeJS.Timeout \| undefined>;
		publish(queue: string, exchange: string, type: string, routingKey: string, data: any): Promise<boolean \| undefined>;
		publish(queue: string, exchange: string, type: string, routingKey: string, bindingKey: string, data: any): Promise<boolean \| undefined>;
		consume(queue: string, onMessage: OnMessage): Promise<Replies.Consume \| undefined>;
		@@ -30,0 +30,0 @@ stopConsume(queue: string): Promise<void>;

New alerts