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

fix DUBBO-49 bug 

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@244 1a56cb94-b969-4eaa-88fa-be21384802f2
This commit is contained in:
tony.chenl 2011-11-10 14:54:30 +00:00
parent d7ca293ecb
commit 3d496c5ea9
2 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java
View File

@ -394,7 +394,6 @@ public class ServiceConfig<T> extends AbstractServiceConfig {
}
}
if ("injvm".equals(protocolConfig.getName())) {
protocolConfig.setPort(0);
protocolConfig.setRegister(false);
map.put("notify", "false");
}

16
dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java
View File

@ -15,12 +15,12 @@
*/
package com.alibaba.dubbo.rpc.protocol.injvm;
import com.alibaba.dubbo.common.Extension;
import com.alibaba.dubbo.common.URL;
import com.alibaba.dubbo.rpc.Exporter;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Protocol;
import com.alibaba.dubbo.rpc.RpcException;
import com.alibaba.dubbo.common.Extension;
import com.alibaba.dubbo.common.URL;
import com.alibaba.dubbo.rpc.Exporter;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Protocol;
import com.alibaba.dubbo.rpc.RpcException;
import com.alibaba.dubbo.rpc.protocol.AbstractProtocol;
/**
@ -40,8 +40,8 @@ public class InjvmProtocol extends AbstractProtocol implements Protocol {
return DEFAULT_PORT;
}
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
return new InjvmExporter<T>(invoker, serviceKey(invoker.getUrl()), exporterMap);
public <T> Exporter<T> export(Invoker<T> invoker) throws RpcException {
return new InjvmExporter<T>(invoker, serviceKey(invoker.getUrl().setPort(DEFAULT_PORT)), exporterMap);
}
public <T> Invoker<T> refer(Class<T> serviceType, URL url) throws RpcException {