Skip to content

Commit 31ef087

Browse files
author
chengyitian
committed
AJ-943: add exception info check for 'getNewLeader' in AbstractClient;
1 parent a7e64c1 commit 31ef087

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

src/com/xxdb/streaming/client/AbstractClient.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1179,6 +1179,10 @@ private DBConnection createSubscribeInternalDBConnection() {
11791179
}
11801180

11811181
public boolean getNewLeader(String s, Object[] hostPort) {
1182+
if (Objects.isNull(s)) {
1183+
return false;
1184+
}
1185+
11821186
int index = s.indexOf("<NotLeader>");
11831187
if (index == -1) {
11841188
return false;

0 commit comments

Comments
 (0)