AJ-642: add default action name for cep unsubscribe;

chengyitian · chengyitian · commit d733957b2079 · 2024-03-26T15:58:59.000+08:00
diff --git a/src/com/xxdb/streaming/cep/EventClient.java b/src/com/xxdb/streaming/cep/EventClient.java
@@ -78,6 +78,8 @@ public void subscribe(String host, int port, String tableName, String actionName
     }
 
     public void unsubscribe(String host, int port, String tableName, String actionName) throws IOException {
+        if (Utils.isEmpty(actionName))
+            actionName = DEFAULT_ACTION_NAME;
         unsubscribeInternal(host, port, tableName, actionName);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -78,6 +78,8 @@ public void subscribe(String host, int port, String tableName, String actionName`
`78`	`78`	`}`
`79`	`79`
`80`	`80`	`public void unsubscribe(String host, int port, String tableName, String actionName) throws IOException {`
	`81`	`+ if (Utils.isEmpty(actionName))`
	`82`	`+ actionName = DEFAULT_ACTION_NAME;`
`81`	`83`	`unsubscribeInternal(host, port, tableName, actionName);`
`82`	`84`	`}`
`83`	`85`