This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch 3.1
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.1 by this push:
new a6ef8910ca Fix 2.6.x LoadBalance SPI not work (#11730)
a6ef8910ca is described below
commit a6ef8910ca7cc2332f23fd4f285d23afe9791849
Author: Xiang Wei Zhang <[email protected]>
AuthorDate: Mon Mar 13 20:15:54 2023 +0800
Fix 2.6.x LoadBalance SPI not work (#11730)
---
dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Invoker.java | 5 +++++
dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Result.java | 5 +++++
2 files changed, 10 insertions(+)
diff --git a/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Invoker.java
b/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Invoker.java
index 5ad026f620..124b063de6 100644
--- a/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Invoker.java
+++ b/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Invoker.java
@@ -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()));
diff --git a/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Result.java
b/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Result.java
index ff690c1dfc..3a1da951c0 100644
--- a/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Result.java
+++ b/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/Result.java
@@ -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();