From dd5e1d7539eaf36fe92f62bde40de4e0b2bc1767 Mon Sep 17 00:00:00 2001
From: ted <ted@teds-MacBook-Pro-2.local>
Date: Wed, 15 Dec 2021 12:09:09 +0700
Subject: [PATCH] feat(channel-msg-reject): send  function to underlying
 channel

---
 src/ChannelWrapper.ts | 5 +++++
 1 file changed, 5 insertions(+)

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<amqplib.Replies.PurgeQueue> {
         if (this._channel) {