From 057e0cd0c8df19fb38564c4c50ce9d8b71699055 Mon Sep 17 00:00:00 2001 From: "william.liangf" Date: Tue, 15 Nov 2011 12:30:30 +0000 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9RMI=E5=85=BC=E5=AE=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit git-svn-id: http://code.alibabatech.com/svn/dubbo/trunk@304 1a56cb94-b969-4eaa-88fa-be21384802f2 --- .../com/alibaba/dubbo/rpc/protocol/rmi/RmiProtocol.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/dubbo-rpc-rmi/src/main/java/com/alibaba/dubbo/rpc/protocol/rmi/RmiProtocol.java b/dubbo-rpc-rmi/src/main/java/com/alibaba/dubbo/rpc/protocol/rmi/RmiProtocol.java index b62199280..cc291a7f4 100644 --- a/dubbo-rpc-rmi/src/main/java/com/alibaba/dubbo/rpc/protocol/rmi/RmiProtocol.java +++ b/dubbo-rpc-rmi/src/main/java/com/alibaba/dubbo/rpc/protocol/rmi/RmiProtocol.java @@ -142,7 +142,13 @@ public class RmiProtocol extends AbstractProtocol { public Invoker refer(Class serviceType, URL url) throws RpcException { Invoker invoker; try { - RmiProtocol.getRemoteClass(serviceType); + try { + if ("dubbo".equals(url.getParameter("codec"))) { + RmiProtocol.getRemoteClass(serviceType); + } + } catch (Throwable t) { + logger.warn(t.getMessage(), t); + } Registry registry = LocateRegistry.getRegistry(url.getHost(), url.getPort()); String path = url.getPath(); if (path == null || path.length() == 0) { -- GitLab