增加手动清除

farseer-go · Dec 10, 2024 · 3d01cf2 · 3d01cf2
1 parent abef071
commit 3d01cf2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pullMessage.go b/pullMessage.go
@@ -54,6 +54,7 @@ func (receiver *subscriber) pullMessage() {
 			err = flog.Error(exp)
 			<-time.After(time.Second)
 		})
+		curQueue.Clear()
 		container.Resolve[trace.IManager]().Push(traceContext, err)
 		asyncLocal.Release()