feat: add primitive.DefaultPanicHandler

apache · Dec 12, 2024 · dc36a37 · dc36a37
1 parent bac8881
commit dc36a37
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
@@ -1111,6 +1111,9 @@ func (pc *pushConsumer) consumeMessageConcurrently(pq *processQueue, mq *primiti
 		go primitive.WithRecover(func() {
 			defer func() {
 				if err := recover(); err != nil {
+					if primitive.DefaultPanicHandler != nil {
+						primitive.DefaultPanicHandler(err)
+					}
 					rlog.Error("consumeMessageConcurrently panic", map[string]interface{}{
 						rlog.LogKeyUnderlayError: err,
 						rlog.LogKeyStack:         utils.GetStackAsString(false),