natas_hw
/
dubbo
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

DUBBO-54 改为获取方法级参数 

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@977 1a56cb94-b969-4eaa-88fa-be21384802f2
This commit is contained in:
william.liangf 2012-02-15 13:03:44 +00:00
parent 6bdf4a4c65
commit ae879965bb
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dubbo-cluster/src/main/java/com/alibaba/dubbo/rpc/cluster/support/MergeableClusterInvoker.java
View File

@ -56,8 +56,9 @@ public class MergeableClusterInvoker<T> implements Invoker<T> {
this.directory = directory;
}
@SuppressWarnings("unchecked")
public Result invoke(final Invocation invocation) throws RpcException {
int timeout = getUrl().getParameter( Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT );
int timeout = getUrl().getMethodParameter(invocation.getMethodName(), Constants.TIMEOUT_KEY, Constants.DEFAULT_TIMEOUT);
List<Invoker<T>> invokers = directory.list(invocation);
Map<String, Future<Result>> results = new HashMap<String, Future<Result>>();
@ -94,7 +95,7 @@ public class MergeableClusterInvoker<T> implements Invoker<T> {
if ( result == null ) {
result = r.getResult();
} else {
String merger = getUrl().getParameter( Constants.MERGER_KEY );
String merger = getUrl().getMethodParameter(invocation.getMethodName(), Constants.MERGER_KEY);
if ( merger != null && ! "".equals( merger.trim() ) ) {
Method method = returnType.getMethod( merger, returnType );
if ( method != null ) {