diff --git a/types/amqp-connection-manager/amqp-connection-manager-tests.ts b/types/amqp-connection-manager/amqp-connection-manager-tests.ts index ea2958cfbb..15f1789751 100644 --- a/types/amqp-connection-manager/amqp-connection-manager-tests.ts +++ b/types/amqp-connection-manager/amqp-connection-manager-tests.ts @@ -24,6 +24,9 @@ channelWrapper.sendToQueue("foo", Buffer.from("bar")) // nothing }); +// Test that plain objects are implicitly serialized. +channelWrapper.sendToQueue("foo", {a: 'bar'}).catch(_ => {}); + // Checking connection options amqpConMgr.connect(["foo", "bar"], { findServers(callback) { diff --git a/types/amqp-connection-manager/index.d.ts b/types/amqp-connection-manager/index.d.ts index 5863a5e314..15a30d25bf 100644 --- a/types/amqp-connection-manager/index.d.ts +++ b/types/amqp-connection-manager/index.d.ts @@ -1,6 +1,7 @@ // Type definitions for amqp-connection-manager 2.0 // Project: https://github.com/benbria/node-amqp-connection-manager // Definitions by: rogierschouten +// tstelzer // Definitions: https://github.com/DefinitelyTyped/DefinitelyTyped // TypeScript Version: 3.2 @@ -158,7 +159,7 @@ export interface ChannelWrapper extends EventEmitter { * @param options * @param callback */ - publish(exchange: string, routingKey: string, content: Buffer, options?: Options.Publish, callback?: (err: any, ok: Replies.Empty) => void): Promise; + publish(exchange: string, routingKey: string, content: Buffer | object, options?: Options.Publish, callback?: (err: any, ok: Replies.Empty) => void): Promise; /** * @see amqplib @@ -167,7 +168,7 @@ export interface ChannelWrapper extends EventEmitter { * @param options * @param callback */ - sendToQueue(queue: string, content: Buffer, options?: Options.Publish, callback?: (err: any, ok: Replies.Empty) => void): Promise; + sendToQueue(queue: string, content: Buffer | object, options?: Options.Publish, callback?: (err: any, ok: Replies.Empty) => void): Promise; /** * @see amqplib