diff --git a/types/amqp-connection-manager/amqp-connection-manager-tests.ts b/types/amqp-connection-manager/amqp-connection-manager-tests.ts index 0ee1aeaf95..6eae738a3c 100644 --- a/types/amqp-connection-manager/amqp-connection-manager-tests.ts +++ b/types/amqp-connection-manager/amqp-connection-manager-tests.ts @@ -18,3 +18,8 @@ connection.on("disconnect", (_arg: { err: Error }): void => undefined); channelWrapper.on("close", () => undefined); channelWrapper.on("connect", () => undefined); channelWrapper.on("error", (_error: Error) => undefined); + +channelWrapper.sendToQueue("foo", Buffer.from("bar")) + .catch((error: Error): void => { + // nothing + }); diff --git a/types/amqp-connection-manager/index.d.ts b/types/amqp-connection-manager/index.d.ts index e8683a4ed6..ab69aadeb1 100644 --- a/types/amqp-connection-manager/index.d.ts +++ b/types/amqp-connection-manager/index.d.ts @@ -146,7 +146,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): boolean; + publish(exchange: string, routingKey: string, content: Buffer, options?: Options.Publish, callback?: (err: any, ok: Replies.Empty) => void): Promise; /** * @see amqplib @@ -155,7 +155,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): boolean; + sendToQueue(queue: string, content: Buffer, options?: Options.Publish, callback?: (err: any, ok: Replies.Empty) => void): Promise; /** * @see amqplib