AJ-692: fix issue about users set when subscribe;

Author: chengyitian

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

@@ -591,7 +591,6 @@ protected BlockingQueue<List<IMessage>> subscribeInternal(String host, int port,
 
                     List<String> tp = Arrays.asList(site.host, String.valueOf(site.port), tableName, actionName);
                     List<String> usr = Arrays.asList(userName, passWord);
-                    users.put(tp, usr);
 
                     params.add(new BasicString(localIP));
                     params.add(new BasicInt(this.listeningPort));
@@ -609,6 +608,7 @@ protected BlockingQueue<List<IMessage>> subscribeInternal(String host, int port,
 
                     re = dbConn.run("publishTable", params);
                     connList.add(dbConn);
+                    users.put(tp, usr);
                 } catch (IOException e) {
                     log.error("Connect to site " + site.host + ":" + site.port + " failed: " + e.getMessage());
                 }
@@ -655,7 +655,6 @@ protected BlockingQueue<List<IMessage>> subscribeInternal(String host, int port,
                 checkServerVersion(host, port);
                 List<String> tp = Arrays.asList(host, String.valueOf(port), tableName, actionName);
                 List<String> usr = Arrays.asList(userName, passWord);
-                users.put(tp, usr);
 
                 dbConn = createSubscribeInternalDBConnection();
                 subscribeInternalConnect(dbConn, host, port, userName, passWord);
@@ -700,6 +699,7 @@ protected BlockingQueue<List<IMessage>> subscribeInternal(String host, int port,
 
                 re = dbConn.run("publishTable", params);
                 connList.add(dbConn);
+                users.put(tp, usr);
                 if (ifUseBackupSite) {
                     synchronized (subInfos_){
                         subInfos_.put(topic, deserializer);