diff --git a/pkg/messaging/target.go b/pkg/messaging/target.go index f5b86daea..96c6e3c00 100644 --- a/pkg/messaging/target.go +++ b/pkg/messaging/target.go @@ -370,6 +370,7 @@ func (s *remoteMessageTarget) runSendMessages(sendCtx context.Context, stream gr zap.Any("messageCenterID", s.messageCenterID), zap.Any("remote", s.targetId)) err = AppError{Type: ErrorTypeMessageSendFailed, Reason: err.Error()} + s.collectErr(err.(AppError)) return err } }