diff --git a/src/ChannelWrapper.ts b/src/ChannelWrapper.ts index 1c271f85..a016a8bd 100644 --- a/src/ChannelWrapper.ts +++ b/src/ChannelWrapper.ts @@ -774,6 +774,11 @@ export default class ChannelWrapper extends EventEmitter { this._channel && this._channel.nackAll(requeue); } + /** Send a `reject` to the underlying channel. */ + reject(message: amqplib.Message, requeue?: boolean): void { + this._channel && this._channel.reject(message, requeue); + } + /** Send a `purgeQueue` to the underlying channel. */ async purgeQueue(queue: string): Promise { if (this._channel) {