| 构造器和说明 |
|---|
SessionWatchers() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
add(Watcher watcher)
new publisher and subscriber data add
|
boolean |
checkWatcherVersions(String dataInfoId,
Long version)
check watchers interest dataInfoId version
if not exist add
else check and update bigger one
|
long |
count()
count pub and sub number
|
boolean |
deleteByConnectId(String connectId)
remove data by client node connectId
|
boolean |
deleteById(String registerId,
String dataInfoId)
remove single data by register id
|
Collection<Watcher> |
getWatchers(String dataInfoId)
query watcher by dataInfoID
|
Map<String,Watcher> |
queryByConnectId(String connectId)
query data by client node connectId
|
public void add(Watcher watcher)
DataManageradd 在接口中 DataManager<Watcher,String,String>public boolean deleteByConnectId(String connectId)
DataManagerdeleteByConnectId 在接口中 DataManager<Watcher,String,String>public boolean checkWatcherVersions(String dataInfoId, Long version)
WatcherscheckWatcherVersions 在接口中 Watcherspublic Collection<Watcher> getWatchers(String dataInfoId)
WatchersgetWatchers 在接口中 Watcherspublic boolean deleteById(String registerId, String dataInfoId)
DataManagerdeleteById 在接口中 DataManager<Watcher,String,String>public Map<String,Watcher> queryByConnectId(String connectId)
DataManagerqueryByConnectId 在接口中 DataManager<Watcher,String,String>public long count()
DataManagercount 在接口中 DataManager<Watcher,String,String>Copyright © 2020 The Ant Financial. All rights reserved.