Skip to content

Commit f5b6d2a

Browse files
CrazyHZMbeiwei30
authored andcommitted
delete useless judgment (#3326)
1 parent df9f998 commit f5b6d2a

File tree

1 file changed

+6
-10
lines changed
  • dubbo-rpc/dubbo-rpc-injvm/src/main/java/org/apache/dubbo/rpc/protocol/injvm

1 file changed

+6
-10
lines changed

dubbo-rpc/dubbo-rpc-injvm/src/main/java/org/apache/dubbo/rpc/protocol/injvm/InjvmProtocol.java

Lines changed: 6 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -93,27 +93,23 @@ public <T> Invoker<T> refer(Class<T> serviceType, URL url) throws RpcException {
9393
}
9494

9595
public boolean isInjvmRefer(URL url) {
96-
final boolean isJvmRefer;
9796
String scope = url.getParameter(Constants.SCOPE_KEY);
9897
// Since injvm protocol is configured explicitly, we don't need to set any extra flag, use normal refer process.
99-
if (Constants.LOCAL_PROTOCOL.toString().equals(url.getProtocol())) {
100-
isJvmRefer = false;
101-
} else if (Constants.SCOPE_LOCAL.equals(scope) || (url.getParameter(Constants.LOCAL_PROTOCOL, false))) {
98+
if (Constants.SCOPE_LOCAL.equals(scope) || (url.getParameter(Constants.LOCAL_PROTOCOL, false))) {
10299
// if it's declared as local reference
103100
// 'scope=local' is equivalent to 'injvm=true', injvm will be deprecated in the future release
104-
isJvmRefer = true;
101+
return true;
105102
} else if (Constants.SCOPE_REMOTE.equals(scope)) {
106103
// it's declared as remote reference
107-
isJvmRefer = false;
104+
return false;
108105
} else if (url.getParameter(Constants.GENERIC_KEY, false)) {
109106
// generic invocation is not local reference
110-
isJvmRefer = false;
107+
return false;
111108
} else if (getExporter(exporterMap, url) != null) {
112109
// by default, go through local reference if there's the service exposed locally
113-
isJvmRefer = true;
110+
return true;
114111
} else {
115-
isJvmRefer = false;
112+
return false;
116113
}
117-
return isJvmRefer;
118114
}
119115
}

0 commit comments

Comments
 (0)