Skip to content

Commit 14f4d23

Browse files
committed
AJ-817: rename test case from resubTimeout to resubscribeInterval
1 parent 5416a17 commit 14f4d23

File tree

3 files changed

+9
-9
lines changed

3 files changed

+9
-9
lines changed

test/com/xxdb/streaming/reverse/PollingClientReverseTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2079,7 +2079,7 @@ public void test_PollingClient_subscribe_backupSites_unsubscribe() throws IOExce
20792079
pollingClient.unsubscribe(HOST,11111,"Trades","subTread1");
20802080
}
20812081
@Test(timeout = 180000)
2082-
public void test_PollingClient_subscribe_resubTimeout_not_true() throws IOException, InterruptedException {
2082+
public void test_PollingClient_subscribe_resubscribeInterval_not_true() throws IOException, InterruptedException {
20832083
String script1 = "st1 = streamTable(1000000:0,`tag`ts`data,[INT,TIMESTAMP,DOUBLE])\n" +
20842084
"share(st1,`Trades)\t\n"
20852085
+ "setStreamTableFilterColumn(objByName(`Trades),`tag)";
@@ -2100,7 +2100,7 @@ public void test_PollingClient_subscribe_resubTimeout_not_true() throws IOExcept
21002100
pollingClient.unsubscribe(HOST,PORT,"Trades","subTread1");
21012101
}
21022102
@Test(timeout = 180000)
2103-
public void test_PollingClient_subscribe_backupSites_resubTimeout() throws Exception {
2103+
public void test_PollingClient_subscribe_backupSites_resubscribeInterval() throws Exception {
21042104
DBConnection controller_conn = new DBConnection();
21052105
controller_conn.connect(controller_host,controller_port,"admin","123456");
21062106
controller_conn.run("try{startDataNode('"+HOST+":"+port_list[1]+"')}catch(ex){}");
@@ -2196,7 +2196,7 @@ public void run() {
21962196
}
21972197

21982198
@Test//(timeout = 180000)
2199-
public void test_PollingClient_subscribe_resubTimeout_subOnce_not_set() throws IOException, InterruptedException {
2199+
public void test_PollingClient_subscribe_resubscribeInterval_subOnce_not_set() throws IOException, InterruptedException {
22002200
DBConnection controller_conn = new DBConnection();
22012201
controller_conn.connect(controller_host,controller_port,"admin","123456");
22022202
controller_conn.run("try{startDataNode('"+HOST+":"+port_list[1]+"')}catch(ex){}");

test/com/xxdb/streaming/reverse/ThreadPooledClientReverseTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1935,7 +1935,7 @@ public void Test_ThreadPooledClient_subscribe_backupSites_unsubscribe() throws I
19351935
threadPooledClient.unsubscribe(HOST,11111,"Trades","subTread1");
19361936
}
19371937
@Test(timeout = 180000)
1938-
public void Test_ThreadPooledClient_subscribe_resubTimeout_not_true() throws IOException, InterruptedException {
1938+
public void Test_ThreadPooledClient_subscribe_resubscribeInterval_not_true() throws IOException, InterruptedException {
19391939
String script1 = "st1 = streamTable(1000000:0,`tag`ts`data,[INT,TIMESTAMP,DOUBLE])\n" +
19401940
"share(st1,`Trades)\t\n"
19411941
+ "setStreamTableFilterColumn(objByName(`Trades),`tag)";
@@ -1968,7 +1968,7 @@ public void doEvent(IMessage msg) {
19681968
};
19691969

19701970
@Test(timeout = 180000)
1971-
public void Test_ThreadPooledClient_subscribe_backupSites_resubTimeout() throws Exception {
1971+
public void Test_ThreadPooledClient_subscribe_backupSites_resubscribeInterval() throws Exception {
19721972
DBConnection controller_conn = new DBConnection();
19731973
controller_conn.connect(controller_host,controller_port,"admin","123456");
19741974
controller_conn.run("try{startDataNode('"+HOST+":"+port_list[1]+"')}catch(ex){}");
@@ -2054,7 +2054,7 @@ public void run() {
20542054
}
20552055

20562056
@Test(timeout = 180000)
2057-
public void Test_ThreadPooledClient_subscribe_resubTimeout_subOnce_not_set() throws IOException, InterruptedException {
2057+
public void Test_ThreadPooledClient_subscribe_resubscribeInterval_subOnce_not_set() throws IOException, InterruptedException {
20582058
DBConnection controller_conn = new DBConnection();
20592059
controller_conn.connect(controller_host,controller_port,"admin","123456");
20602060
controller_conn.run("try{startDataNode('"+HOST+":"+port_list[1]+"')}catch(ex){}");

test/com/xxdb/streaming/reverse/ThreadedClientsubscribeReverseTest.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3510,7 +3510,7 @@ public void test_ThreadClient_subscribe_backupSites_unsubscribe() throws IOExcep
35103510
threadedClient.unsubscribe(HOST,11111,"Trades","subTread1");
35113511
}
35123512
@Test(timeout = 180000)
3513-
public void test_ThreadClient_subscribe_resubTimeout_not_true() throws IOException, InterruptedException {
3513+
public void test_ThreadClient_subscribe_resubscribeInterval_not_true() throws IOException, InterruptedException {
35143514
String script1 = "st1 = streamTable(1000000:0,`tag`ts`data,[INT,TIMESTAMP,DOUBLE])\n" +
35153515
"share(st1,`Trades)\t\n"
35163516
+ "setStreamTableFilterColumn(objByName(`Trades),`tag)";
@@ -3541,7 +3541,7 @@ public void doEvent(IMessage msg) {
35413541
}
35423542
};
35433543
@Test(timeout = 180000)
3544-
public void test_ThreadClient_subscribe_backupSites_resubTimeout() throws Exception {
3544+
public void test_ThreadClient_subscribe_backupSites_resubscribeInterval() throws Exception {
35453545
DBConnection controller_conn = new DBConnection();
35463546
controller_conn.connect(controller_host,controller_port,"admin","123456");
35473547
controller_conn.run("try{startDataNode('"+HOST+":"+port_list[1]+"')}catch(ex){}");
@@ -3627,7 +3627,7 @@ public void run() {
36273627
}
36283628

36293629
@Test(timeout = 180000)
3630-
public void Test_ThreadClient_subscribe_resubTimeout_subOnce_not_set() throws IOException, InterruptedException {
3630+
public void Test_ThreadClient_subscribe_resubscribeInterval_subOnce_not_set() throws IOException, InterruptedException {
36313631
DBConnection controller_conn = new DBConnection();
36323632
controller_conn.connect(controller_host,controller_port,"admin","123456");
36333633
controller_conn.run("try{startDataNode('"+HOST+":"+port_list[1]+"')}catch(ex){}");

0 commit comments

Comments
 (0)