You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by vi...@apache.org on 2019/09/17 01:58:41 UTC
[dubbo] branch master updated: fix 4694: consumer return quickly,
when the provider interrupts abnormally (#4698)
This is an automated email from the ASF dual-hosted git repository.
victory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new a89b24c fix 4694: consumer return quickly, when the provider interrupts abnormally (#4698)
a89b24c is described below
commit a89b24c5d1d4c8636b37e6a5d59169087338f89f
Author: Zhiwei Zhao <zh...@126.com>
AuthorDate: Tue Sep 17 09:58:30 2019 +0800
fix 4694: consumer return quickly, when the provider interrupts abnormally (#4698)
---
.../dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java
index 2529ac7..e04f930 100644
--- a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java
+++ b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java
@@ -131,6 +131,8 @@ final class HeaderExchangeChannel implements ExchangeChannel {
@Override
public void close() {
try {
+ // graceful close
+ DefaultFuture.closeChannel(channel);
channel.close();
} catch (Throwable e) {
logger.warn(e.getMessage(), e);