AJ-437: deprecate DBConnection's isReverseStreaming param.

Author: chengyitian

src/com/xxdb/DBConnection.java

@@ -177,6 +177,18 @@ private DBConnectionImpl(boolean asynTask, boolean sslEnable, boolean compress,
             this.lock_ = new ReentrantLock();
         }
 
+        private DBConnectionImpl(boolean asynTask, boolean sslEnable, boolean compress, boolean python, boolean ifUrgent, SqlStdEnum sqlStd){
+            sessionID_ = "";
+            this.sslEnable_ = sslEnable;
+            this.asynTask_ = asynTask;
+            this.compress_ = compress;
+            this.ifUrgent_ = ifUrgent;
+            this.python_ = python;
+            this.isReverseStreaming_ = false;
+            this.sqlStd_ = sqlStd;
+            this.lock_ = new ReentrantLock();
+        }
+
         private boolean connect(String hostName, int port, String userId, String password, int connTimeout) throws IOException{
             this.hostName_ = hostName;
             this.port_ = port;
@@ -572,12 +584,16 @@ public ExtendedDataInput getDataInputStream() {
         }
     }
 
+    private DBConnectionImpl createEnableReverseStreamingDBConnectionImpl(boolean asynTask, boolean sslEnable, boolean compress, boolean python, boolean ifUrgent, SqlStdEnum sqlStd) {
+        return new DBConnectionImpl(asynTask, sslEnable, compress, python, ifUrgent, true, sqlStd);
+    }
+
     public DBConnection() {
     	this(false, false, false);
     }
 
     public DBConnection(SqlStdEnum sqlStd) {
-        this(false, false, false, false, false, false, sqlStd);
+        this(false, false, false, false, false, sqlStd);
     }
 
     public DBConnection(boolean asynchronousTask) {
@@ -593,25 +609,39 @@ public DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress)
     }
 
     public DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython){
-        this.conn_ = new DBConnectionImpl(asynchronousTask, useSSL, compress, usePython, false, false, SqlStdEnum.DolphinDB);
+        this.conn_ = new DBConnectionImpl(asynchronousTask, useSSL, compress, usePython, false, SqlStdEnum.DolphinDB);
         this.mutex_ = new ReentrantLock();
     }
 
 
     public DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, SqlStdEnum sqlStd){
-        this.conn_ = new DBConnectionImpl(asynchronousTask, useSSL, compress, usePython, false, false, sqlStd);
+        this.conn_ = new DBConnectionImpl(asynchronousTask, useSSL, compress, usePython, false, sqlStd);
         this.mutex_ = new ReentrantLock();
     }
 
     public DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent){
-        this.conn_ = new DBConnectionImpl(asynchronousTask, useSSL, compress, usePython, isUrgent, false, SqlStdEnum.DolphinDB);
+        this.conn_ = new DBConnectionImpl(asynchronousTask, useSSL, compress, usePython, isUrgent, SqlStdEnum.DolphinDB);
         this.mutex_ = new ReentrantLock();
     }
 
+    public DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent, SqlStdEnum sqlStd){
+        this.conn_ = new DBConnectionImpl(asynchronousTask, useSSL, compress, usePython, isUrgent, sqlStd);
+        this.mutex_ = new ReentrantLock();
+    }
+
+    @Deprecated
     public DBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent, boolean isReverseStreaming, SqlStdEnum sqlStd){
         this.conn_ = new DBConnectionImpl(asynchronousTask, useSSL, compress, usePython, isUrgent, isReverseStreaming, sqlStd);
         this.mutex_ = new ReentrantLock();
     }
+
+    public static DBConnection internalCreateEnableReverseStreamingDBConnection(boolean asynchronousTask, boolean useSSL, boolean compress, boolean usePython, boolean isUrgent, SqlStdEnum sqlStd) {
+        DBConnection dbConnection = new DBConnection();
+        dbConnection.conn_ = dbConnection.createEnableReverseStreamingDBConnectionImpl(asynchronousTask, useSSL, compress, usePython, isUrgent, sqlStd);
+        dbConnection.mutex_ = new ReentrantLock();
+
+        return dbConnection;
+    }
 
     public boolean isBusy() {
         if (!mutex_.tryLock())

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

@@ -426,7 +426,7 @@ protected BlockingQueue<List<IMessage>> subscribeInternal(String host, int port,
         if (listeningPort > 0)
             dbConn = new DBConnection();
         else
-            dbConn = new DBConnection(false, false, false, false, false, true, SqlStdEnum.DolphinDB);
+            dbConn = DBConnection.internalCreateEnableReverseStreamingDBConnection(false, false, false, false, false, SqlStdEnum.DolphinDB);
 
         if (!userName.equals(""))
             dbConn.connect(host, port, userName, passWord);