AJ-674: delete no use after-try tryReconnect;

Author: chengyitian

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

@@ -321,7 +321,7 @@ public boolean tryReconnect(String topic) {
 //                log.info("Successfully switched to node: " + sites[currentSiteIndexMap.get(topic)].host + ":" + sites[currentSiteIndexMap.get(topic)].port);
 
                 if (!reconnected) {
-                    waitReconnectTopic.add(topic);
+                    // waitReconnectTopic.add(topic);
                     return false;
                 } else {
                     log.info("Successfully switched to node: " + sites[currentSiteIndexMap.get(topic)].host + ":" + sites[currentSiteIndexMap.get(topic)].port);

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

@@ -195,15 +195,20 @@ public void run() {
                         }
                     }
 
-                    Set<String> waitReconnectTopic = dispatcher.getAllReconnectTopic();
-                    synchronized (waitReconnectTopic) {
-                        for (String topic : waitReconnectTopic) {
-                            // reconnect every info.resubTimeout ms
-                            if (System.currentTimeMillis() - AbstractClient.lastExceptionTopicTimeMap.get(topic) <= AbstractClient.resubTimeout)
-                                continue;
-                            dispatcher.tryReconnect(topic);
-                        }
-                    }
+                    // not need to put and get from waitReconnectTopic.
+//                    Set<String> waitReconnectTopic = dispatcher.getAllReconnectTopic();
+//                    synchronized (waitReconnectTopic) {
+//                        for (String topic : waitReconnectTopic) {
+//                            // reconnect every info.resubTimeout ms
+////                            if (System.currentTimeMillis() - AbstractClient.lastExceptionTopicTimeMap.get(topic) <= AbstractClient.resubTimeout)
+////                                continue;
+//                            long subTime = System.currentTimeMillis() - AbstractClient.lastExceptionTopicTimeMap.get(topic);
+//                            System.out.println("flag3 subTime: " + subTime);
+//                            if (subTime <= AbstractClient.resubTimeout)
+//                                continue;
+//                            dispatcher.tryReconnect(topic);
+//                        }
+//                    }
 
                     try {
                         // check reconnected interval time