diff --git a/pkg/client/dubbo/config.go b/pkg/client/dubbo/config.go index c4055913c..f4e56a97f 100644 --- a/pkg/client/dubbo/config.go +++ b/pkg/client/dubbo/config.go @@ -33,6 +33,8 @@ type DubboProxyConfig struct { AutoResolve bool `yaml:"auto_resolve" json:"auto_resolve,omitempty"` // Protoset path to load protoset files Protoset []string `yaml:"protoset" json:"protoset,omitempty"` - // Load + // Load balance LoadBalance string `yaml:"load_balance" json:"load_balance,omitempty"` + // Retries number of retries + Retries string `yaml:"retries" json:"retries,omitempty"` } diff --git a/pkg/client/dubbo/dubbo.go b/pkg/client/dubbo/dubbo.go index ad323caf2..ca3e61c3e 100644 --- a/pkg/client/dubbo/dubbo.go +++ b/pkg/client/dubbo/dubbo.go @@ -319,12 +319,15 @@ func (dc *Client) create(key string, irequest fc.IntegrationRequest) *generic.Ge Version: irequest.DubboBackendConfig.Version, Group: irequest.Group, Loadbalance: dc.dubboProxyConfig.LoadBalance, + Retries: dc.dubboProxyConfig.Retries, } - if len(irequest.DubboBackendConfig.Retries) == 0 { - refConf.Retries = "3" - } else { - refConf.Retries = irequest.DubboBackendConfig.Retries + if refConf.Retries == "" { + if len(irequest.DubboBackendConfig.Retries) == 0 { + refConf.Retries = "3" + } else { + refConf.Retries = irequest.DubboBackendConfig.Retries + } } if dc.dubboProxyConfig.Timeout != nil {