Merge branch 'master' of github.com:abreits/amqp-ts

abreits · Oct 9, 2019 · fb19802 · fb19802
2 parents 92a5008 + 8d9f3e6
commit fb19802
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git 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<Message>;
     prefetch(count: number): void;
     recover(): Promise<void>;

diff --git a/lib/amqp-ts.js b/lib/amqp-ts.js
diff --git 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<Message> {