diff --git a/amqplib/amqplib-tests.ts b/amqplib/amqplib-tests.ts index 134306e51e..9a15e250f4 100644 --- a/amqplib/amqplib-tests.ts +++ b/amqplib/amqplib-tests.ts @@ -24,6 +24,7 @@ amqp.connect("amqp://localhost") // test promise api properties var amqpMessage: amqp.Message; +amqpMessage.properties.contentType === "application/json"; var amqpAssertExchangeOptions: amqp.Options.AssertExchange; var anqpAssertExchangeReplies: amqp.Replies.AssertExchange; @@ -61,5 +62,6 @@ amqpcb.connect("amqp://localhost", (err, connection) => { // test callback api properties var amqpcbMessage: amqp.Message; +amqpMessage.properties.contentType === "application/json"; 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 0c76495efc..d03c46ed79 100644 --- a/amqplib/amqplib.d.ts +++ b/amqplib/amqplib.d.ts @@ -66,7 +66,7 @@ declare module "amqplib/properties" { contentType?: string; contentEncoding?: string; - headers?: Object; + headers?: any; priority?: number; correlationId?: string; replyTo?: string; @@ -81,7 +81,7 @@ declare module "amqplib/properties" { noAck?: boolean; exclusive?: boolean; priority?: number; - arguments?: Object; + arguments?: any; } interface Get { noAck?: boolean; @@ -90,8 +90,8 @@ declare module "amqplib/properties" { interface Message { content: Buffer; - fields: Object; - properties: Object; + fields: any; + properties: any; } }