apache/dubbo
apache/dubbo
1
0
Fork 0
mirror of https://github.com/apache/dubbo.git synced 2024-10-23 07:04:37 +08:00
Code Issues Projects Releases Wiki Activity

Fix 2.6.x LoadBalance SPI not work (#11730)

Browse Source
This commit is contained in:
Xiang Wei Zhang 2023-03-13 20:15:54 +08:00 committed by GitHub
parent ffb2bbbffc
commit a6ef8910ca
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Invoker.java
View File

@ -50,6 +50,11 @@ public interface Invoker<T> extends org.apache.dubbo.rpc.Invoker<T> {
return invoker.getInterface();
}
@Override
public org.apache.dubbo.rpc.Result invoke(org.apache.dubbo.rpc.Invocation invocation) throws org.apache.dubbo.rpc.RpcException {
return new Result.CompatibleResult(invoker.invoke(invocation));
}
@Override
public Result invoke(Invocation invocation) throws RpcException {
return new Result.CompatibleResult(invoker.invoke(invocation.getOriginal()));

5
dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Result.java
View File

@ -103,6 +103,11 @@ public interface Result extends org.apache.dubbo.rpc.Result {
return delegate;
}
@Override
public org.apache.dubbo.rpc.Result whenCompleteWithContext(BiConsumer<org.apache.dubbo.rpc.Result, Throwable> fn) {
return delegate.whenCompleteWithContext(fn);
}
@Override
public Object getValue() {
return delegate.getValue();