From 9d8cb8928490f0710b01809987e2d8af1b9903a7 Mon Sep 17 00:00:00 2001 From: abreits Date: Thu, 22 Oct 2015 13:06:26 +0200 Subject: [PATCH] amqplib: exposed Option and Reply properties again (bugfix) --- amqplib/amqplib-tests.ts | 12 ++++++++++++ amqplib/amqplib.d.ts | 12 ++++++------ 2 files changed, 18 insertions(+), 6 deletions(-) diff --git a/amqplib/amqplib-tests.ts b/amqplib/amqplib-tests.ts index f99a3bde1..134306e51 100644 --- a/amqplib/amqplib-tests.ts +++ b/amqplib/amqplib-tests.ts @@ -5,6 +5,7 @@ import amqp = require("amqplib"); var msg = "Hello World"; +// test promise api amqp.connect("amqp://localhost") .then(connection => { return connection.createChannel() @@ -21,6 +22,12 @@ amqp.connect("amqp://localhost") .ensure(() => connection.close()); }); +// test promise api properties +var amqpMessage: amqp.Message; +var amqpAssertExchangeOptions: amqp.Options.AssertExchange; +var anqpAssertExchangeReplies: amqp.Replies.AssertExchange; + + // callback api tests import amqpcb = require("amqplib/callback_api"); @@ -51,3 +58,8 @@ amqpcb.connect("amqp://localhost", (err, connection) => { }); } }); + +// test callback api properties +var amqpcbMessage: amqp.Message; +var amqpcbAssertExchangeOptions: amqp.Options.AssertExchange; +var anqpcbAssertExchangeReplies: amqp.Replies.AssertExchange; \ No newline at end of file diff --git a/amqplib/amqplib.d.ts b/amqplib/amqplib.d.ts index f125aaa07..0c76495ef 100644 --- a/amqplib/amqplib.d.ts +++ b/amqplib/amqplib.d.ts @@ -100,9 +100,9 @@ declare module "amqplib" { import events = require("events"); import when = require("when"); import shared = require("amqplib/properties") - import Replies = shared.Replies; - import Options = shared.Options; - import Message = shared.Message; + export import Replies = shared.Replies; + export import Options = shared.Options; + export import Message = shared.Message; interface Connection extends events.EventEmitter { close(): when.Promise; @@ -156,9 +156,9 @@ declare module "amqplib/callback_api" { import events = require("events"); import shared = require("amqplib/properties") - import Replies = shared.Replies; - import Options = shared.Options; - import Message = shared.Message; + export import Replies = shared.Replies; + export import Options = shared.Options; + export import Message = shared.Message; interface Connection extends events.EventEmitter { close(callback?: (err: any) => void): void;