From 04a15cbd8dd23f68da352c96c8c22e6f17da3e24 Mon Sep 17 00:00:00 2001
From: finley <hdt3213@outlook.com>
Date: Sun, 19 Jan 2025 08:07:47 +0800
Subject: [PATCH] let consume buffer naturally depletion

---
 delayqueue.go | 1 -
 1 file changed, 1 deletion(-)

diff --git a/delayqueue.go b/delayqueue.go
index de25d90..1301b30 100644
--- a/delayqueue.go
+++ b/delayqueue.go
@@ -674,7 +674,6 @@ func (q *DelayQueue) StopConsume() {
 	if q.ticker != nil {
 		q.ticker.Stop()
 	}
-	close(q.consumeBuffer)
 }
 
 // GetPendingCount returns the number of pending messages