AJ-690: init backupSites related params when unsubscribe.

Author: chengyitian

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

@@ -213,6 +213,13 @@ protected void unsubscribeInternal(String host, int port, String tableName, Stri
                 // synchronized (queueManager) {
                 queueManager.removeQueue(topic);
                 // }
+
+                // init backupSites related params.
+                if (AbstractClient.ifUseBackupSite) {
+                    AbstractClient.ifUseBackupSite = false;
+                    AbstractClient.subOnce = false;
+                    AbstractClient.resubTimeout = 100;
+                }
                 log.info("Successfully unsubscribed table " + fullTableName);
             } catch (Exception ex) {
                 throw ex;

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

@@ -382,6 +382,13 @@ protected void unsubscribeInternal(String host, int port, String tableName, Stri
                     // synchronized (queueManager) {
                     queueManager.removeQueue(topic);
                     // }
+
+                    // init backupSites related params.
+                    if (AbstractClient.ifUseBackupSite) {
+                        AbstractClient.ifUseBackupSite = false;
+                        AbstractClient.subOnce = false;
+                        AbstractClient.resubTimeout = 100;
+                    }
                     log.info("Successfully unsubscribed table " + fullTableName);
                 } catch (Exception ex) {
                     throw ex;

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

@@ -546,6 +546,13 @@ protected void unsubscribeInternal(String host, int port, String tableName, Stri
                     // synchronized (queueManager) {
                     queueManager.removeQueue(lastBackupSiteTopic);
                     // }
+
+                    // init backupSites related params.
+                    if (AbstractClient.ifUseBackupSite) {
+                        AbstractClient.ifUseBackupSite = false;
+                        AbstractClient.subOnce = false;
+                        AbstractClient.resubTimeout = 100;
+                    }
                     log.info("Successfully unsubscribed table " + fullTableName);
                 } catch (Exception ex) {
                     throw ex;