From af0be968418e4ed0b74b3f0105f4104cffb3b5d5 Mon Sep 17 00:00:00 2001
From: Shigure42 <exhours@gmail.com>
Date: Thu, 6 Mar 2025 10:12:19 +0800
Subject: [PATCH] Fix: WithLogger doesn't work when cause consume error

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

diff --git a/delayqueue.go b/delayqueue.go
index 491e77f..1b6d81d 100644
--- a/delayqueue.go
+++ b/delayqueue.go
@@ -764,7 +764,7 @@ func (q *DelayQueue) StartConsume() (done <-chan struct{}) {
 			case <-q.ticker.C:
 				ids, err := q.beforeConsume()
 				if err != nil {
-					log.Printf("consume error: %v", err)
+					q.logger.Printf("consume error: %v", err)
 				}
 				q.goWithRecover(func() {
 					for _, id := range ids {