From 84f612eb26f91f94091666b4c39eb501a1d14da3 Mon Sep 17 00:00:00 2001
From: pantianying <601666418@qq.com>
Date: Mon, 6 Jan 2020 17:37:37 +0800
Subject: [PATCH] fix bug
---
config/reference_config.go | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/config/reference_config.go b/config/reference_config.go
index 4896c6db1..35c051e7d 100644
--- a/config/reference_config.go
+++ b/config/reference_config.go
@@ -143,7 +143,13 @@ func (refconfig *ReferenceConfig) Refer() {
}
//create proxy
- refconfig.pxy = extension.GetProxyFactory(consumerConfig.ProxyFactory).GetProxy(refconfig.invoker, url)
+ if refconfig.Async {
+ refconfig.pxy = extension.GetProxyFactory(consumerConfig.ProxyFactory).GetProxy(refconfig.invoker, url)
+ callback := GetCallback(refconfig.id)
+ refconfig.pxy = extension.GetProxyFactory(consumerConfig.ProxyFactory).GetAsyncProxy(refconfig.invoker, callback, url)
+ } else {
+ refconfig.pxy = extension.GetProxyFactory(consumerConfig.ProxyFactory).GetProxy(refconfig.invoker, url)
+ }
}
// @v is service provider implemented RPCService
--
GitLab