浏览代码

add `Socket closed` variant to NetworkExceptionHelper.isCloseConnectionException

Boaz Leskes 9 年之前
父节点
当前提交
8151224883
共有 1 个文件被更改,包括 3 次插入0 次删除
  1. 3 0
      core/src/main/java/org/elasticsearch/common/transport/NetworkExceptionHelper.java

+ 3 - 0
core/src/main/java/org/elasticsearch/common/transport/NetworkExceptionHelper.java

@@ -58,6 +58,9 @@ public class NetworkExceptionHelper {
             if (e.getMessage().equals("Socket is closed")) {
                 return true;
             }
+            if (e.getMessage().equals("Socket closed")) {
+                return true;
+            }
         }
         return false;
     }