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