fix to#1207 (#1214)

fuyou001 · web-flow · commit 33fe267de2d6 · 2025-08-21T20:11:09.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`	`}`