update lock expire time error if lock all success

ShannonDing · ShannonDing · commit 719c49f15ea9 · 2025-08-21T17:45:00.000+08:00
diff --git a/consumer/consumer.go b/consumer/consumer.go
@@ -578,7 +578,7 @@ func (dc *defaultConsumer) lockAll() {
 			if exist {
 				pq := v.(*processQueue)
 				pq.WithLock(true)
-				pq.UpdateLastConsumeTime()
+				pq.UpdateLastLockTime()
 			}
 			set[_mq] = true
 		}

Original file line number	Diff line number	Diff line change
`@@ -578,7 +578,7 @@ func (dc *defaultConsumer) lockAll() {`
`578`	`578`	`if exist {`
`579`	`579`	`pq := v.(*processQueue)`
`580`	`580`	`pq.WithLock(true)`
`581`		`- pq.UpdateLastConsumeTime()`
	`581`	`+ pq.UpdateLastLockTime()`
`582`	`582`	`}`
`583`	`583`	`set[_mq] = true`
`584`	`584`	`}`