getStreamingStat函数能查到订阅情况,下面函数可以批量取消某个表的所有订阅
def unsubscribeAll(tabName) {
t = getStreamingStat().pubTables
for(row in t){
if(string(row.actions).startsWith("[")) {
actions = split(substr(row.actions, 1, strlen(row.actions)-2), ",")
} else {
actions = [].append!(row.actions)
}
for(action in actions){
unsubscribeTable(tableName=tabName, actionName=action)
}
}
}