You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by al...@apache.org on 2023/03/13 12:16:04 UTC
[dubbo] branch 3.1 updated: Fix 2.6.x LoadBalance SPI not work (#11730)
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 <zx...@hotmail.com>
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();