diff --git a/lib/amqp-ts.d.ts b/lib/amqp-ts.d.ts index 17a71bbd..11e95723 100644 --- a/lib/amqp-ts.d.ts +++ b/lib/amqp-ts.d.ts @@ -104,7 +104,7 @@ export declare class Exchange { constructor(connection: Connection, name: string, type?: string, options?: Exchange.DeclarationOptions); _initialize(): void; /** - * deprecated, use 'exchange.send(message: Message)' instead + * deprecated, use 'exchange.send(message: Message, routingKey?: string)' instead */ publish(content: any, routingKey?: string, options?: any): void; send(message: Message, routingKey?: string): void; @@ -158,7 +158,7 @@ export declare class Queue { * deprecated, use 'queue.send(message: Message)' instead */ publish(content: any, options?: any): void; - send(message: Message, routingKey?: string): void; + send(message: Message): void; rpc(requestParameters: any): Promise; prefetch(count: number): void; recover(): Promise; diff --git a/lib/amqp-ts.js b/lib/amqp-ts.js index fcac5189..4aa40390 100644 --- a/lib/amqp-ts.js +++ b/lib/amqp-ts.js @@ -455,7 +455,7 @@ var Exchange = (function () { this._connection._exchanges[this._name] = this; }; /** - * deprecated, use 'exchange.send(message: Message)' instead + * deprecated, use 'exchange.send(message: Message, routingKey?: string)' instead */ Exchange.prototype.publish = function (content, routingKey, options) { var _this = this; diff --git a/src/amqp-ts.ts b/src/amqp-ts.ts index ef1890fe..385effd6 100644 --- a/src/amqp-ts.ts +++ b/src/amqp-ts.ts @@ -502,7 +502,7 @@ export class Exchange { } /** - * deprecated, use 'exchange.send(message: Message)' instead + * deprecated, use 'exchange.send(message: Message, routingKey?: string)' instead */ publish(content: any, routingKey = "", options: any = {}): void { if (typeof content === "string") { @@ -838,8 +838,8 @@ export class Queue { } } - send(message: Message, routingKey = ""): void { - message.sendTo(this, routingKey); + send(message: Message): void { + message.sendTo(this); } rpc(requestParameters: any): Promise {