From ef2b897324f6db46e162c676481683d9f9437a78 Mon Sep 17 00:00:00 2001
From: Gregor Yushinov <weeco@users.noreply.github.com>
Date: Wed, 15 Nov 2017 17:48:25 +0100
Subject: [PATCH] Accept a connection object instead of a URL

---
 types/amqplib/index.d.ts      |  2 +-
 types/amqplib/properties.d.ts | 60 ++++++++++++++++++++++++++++++++++-
 2 files changed, 60 insertions(+), 2 deletions(-)

diff --git a/types/amqplib/index.d.ts b/types/amqplib/index.d.ts
index 91060d23b0..2d5cb3ba99 100644
--- a/types/amqplib/index.d.ts
+++ b/types/amqplib/index.d.ts
@@ -63,4 +63,4 @@ export interface ConfirmChannel extends Channel {
     waitForConfirms(): Promise<void>;
 }
 
-export function connect(url: string, socketOptions?: any): Promise<Connection>;
+export function connect(url: string | Options.Connect, socketOptions?: any): Promise<Connection>;
diff --git a/types/amqplib/properties.d.ts b/types/amqplib/properties.d.ts
index 12514d7810..af90909d8c 100644
--- a/types/amqplib/properties.d.ts
+++ b/types/amqplib/properties.d.ts
@@ -21,6 +21,64 @@ export namespace Replies {
 }
 
 export namespace Options {
+    interface Connect {
+        /**
+         * The to be used protocol
+         *
+         * Default value: 'amqp'
+         */
+        protocol?: string;
+        /**
+         * Hostname used for connecting to the server.
+         *
+         * Default value: 'localhost'
+         */
+        hostname?: string;
+        /**
+         * Port used for connecting to the server.
+         *
+         * Default value: 5672
+         */
+        port?: number;
+        /**
+         * Username used for authenticating against the server.
+         *
+         * Default value: 'guest'
+         */
+        username?: string;
+        /**
+         * Password used for authenticating against the server.
+         *
+         * Default value: 'guest'
+         */
+        password?: string;
+        /**
+         * The desired locale for error messages. RabbitMQ only ever uses en_US
+         *
+         * Default value: 'en_US'
+         */
+        locale?: string;
+        /**
+         * The size in bytes of the maximum frame allowed over the connection. 0 means
+         * no limit (but since frames have a size field which is an unsigned 32 bit integer, it’s perforce 2^32 - 1).
+         *
+         * Default value: 0x1000 (4kb) - That's the allowed minimum, it will fit many purposes
+         */
+        frameMax?: number;
+        /**
+         * The period of the connection heartbeat in seconds.
+         *
+         * Default value: 0
+         */
+        heartbeat?: number;
+        /**
+         * What VHost shall be used.
+         *
+         * Default value: '/'
+         */
+        vhost?: string;
+    }
+
     interface AssertQueue {
         exclusive?: boolean;
         durable?: boolean;
@@ -85,4 +143,4 @@ export interface Message {
     content: Buffer;
     fields: any;
     properties: any;
-}
\ No newline at end of file
+}