Fix: WithLogger doesn't work when cause consume error

Shigure42 · HDT3213 · commit 2bb986cab4c8 · 2025-03-20T14:22:01.000+08:00
diff --git 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 {

Original file line number	Diff line number	Diff line change
`@@ -764,7 +764,7 @@ func (q *DelayQueue) StartConsume() (done <-chan struct{}) {`
`764`	`764`	`case <-q.ticker.C:`
`765`	`765`	`ids, err := q.beforeConsume()`
`766`	`766`	`if err != nil {`
`767`		`- log.Printf("consume error: %v", err)`
	`767`	`+ q.logger.Printf("consume error: %v", err)`
`768`	`768`	`}`
`769`	`769`	`q.goWithRecover(func() {`
`770`	`770`	`for _, id := range ids {`