diff --git a/common/proxy/proxy.go b/common/proxy/proxy.go index c91aafecd7b0c21b034365ce92292e1cb82e455d..3a01941700ed277d9481c6c57a739c69f83b06b7 100644 --- a/common/proxy/proxy.go +++ b/common/proxy/proxy.go @@ -234,3 +234,8 @@ func (p *Proxy) Get() common.RPCService { func (p *Proxy) GetCallback() interface{} { return p.callBack } + +// GetInvoker gets Invoker. +func (p *Proxy) GetInvoker() protocol.Invoker { + return p.invoke +} diff --git a/config/reference_config.go b/config/reference_config.go index 05df3477362561644a841b147d67a660536ffdbc..28cd0feb77fd152e79ccab70f00a2d7164f34188 100644 --- a/config/reference_config.go +++ b/config/reference_config.go @@ -185,6 +185,11 @@ func (c *ReferenceConfig) GetRPCService() common.RPCService { return c.pxy.Get() } +// GetProxy gets proxy +func (c *ReferenceConfig) GetProxy() *proxy.Proxy { + return c.pxy +} + func (c *ReferenceConfig) getUrlMap() url.Values { urlMap := url.Values{} //first set user params