From 3d496c5ea97fc16fae0b4260c4d721e9c357bcac Mon Sep 17 00:00:00 2001
From: "tony.chenl" <tony.chenl@1a56cb94-b969-4eaa-88fa-be21384802f2>
Date: Thu, 10 Nov 2011 14:54:30 +0000
Subject: [PATCH] fix DUBBO-49 bug

git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@244 1a56cb94-b969-4eaa-88fa-be21384802f2
---
 .../com/alibaba/dubbo/config/ServiceConfig.java  |  1 -
 .../dubbo/rpc/protocol/injvm/InjvmProtocol.java  | 16 ++++++++--------
 2 files changed, 8 insertions(+), 9 deletions(-)

diff --git a/dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java b/dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java
index e07dae0125..c7c00483c5 100644
--- a/dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java
+++ b/dubbo-config/src/main/java/com/alibaba/dubbo/config/ServiceConfig.java
@@ -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");
             }
diff --git a/dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java b/dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java
index 325c40990f..a3e81392f6 100644
--- a/dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java
+++ b/dubbo-rpc-injvm/src/main/java/com/alibaba/dubbo/rpc/protocol/injvm/InjvmProtocol.java
@@ -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 {