Fix: WithLogger doesn't work when cause consume error

2025-10-22 22:59:22 +08:00 · 2025-03-06 10:12:19 +08:00
parent 7816eb01de
commit 2bb986cab4
1 changed files with 1 additions and 1 deletions
--- 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 {