Skip to content

Commit 004f5f0

Browse files
author
chengyitian
committed
AJ-690: modify backupSites related params init time after parsed backupSites;
1 parent 88f1423 commit 004f5f0

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -540,10 +540,6 @@ protected BlockingQueue<List<IMessage>> subscribeInternal(String host, int port,
540540

541541
List<Site> parsedBackupSites = new ArrayList<>();
542542
if (Objects.nonNull(backupSites) && !backupSites.isEmpty()) {
543-
AbstractClient.resubTimeout = resubTimeout;
544-
AbstractClient.subOnce = subOnce;
545-
AbstractClient.ifUseBackupSite = true;
546-
// AbstractClient.createSubInfo = createSubInfo;
547543
// prepare backupSites
548544
for (int i = 0; i < backupSites.size() + 1; i++) {
549545
if (i == 0) {
@@ -559,6 +555,10 @@ protected BlockingQueue<List<IMessage>> subscribeInternal(String host, int port,
559555
}
560556
}
561557

558+
AbstractClient.resubTimeout = resubTimeout;
559+
AbstractClient.subOnce = subOnce;
560+
AbstractClient.ifUseBackupSite = true;
561+
562562
boolean isConnected = false;
563563
for (int i = 0; i < parsedBackupSites.size() && !isConnected; i++) {
564564
Site site = parsedBackupSites.get(i);

0 commit comments

Comments
 (0)