amqplib: exposed Option and Reply properties again (bugfix)

This commit is contained in:
abreits
2015-10-22 13:06:26 +02:00
parent 754264b378
commit 9d8cb89284
2 changed files with 18 additions and 6 deletions
+12
View File
@@ -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;
+6 -6
View File
@@ -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<void>;
@@ -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;