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();

Reply via email to