public abstract class AbstractDataManager<T extends BaseInfo> extends Object implements DataManager<T,String,String>
| 限定符和类型 | 字段和说明 |
|---|---|
protected Logger |
logger |
protected SessionServerConfig |
sessionServerConfig |
| 限定符和类型 | 方法和说明 |
|---|---|
protected Tuple<T,Boolean> |
addData(T data) |
Tuple<Long,Long> |
count()
dataInfoId.size and data.size
|
Map<String,T> |
deleteByConnectId(ConnectId connectId)
remove data by client node connectId
|
Map<ConnectId,Map<String,T>> |
deleteByConnectIds(Set<ConnectId> connectIds)
remove data by client node connectIds
|
T |
deleteById(String registerId,
String dataInfoId)
remove single data by register id
|
void |
forEach(java.util.function.BiConsumer<String,Map<String,T>> consumer) |
Set<ConnectId> |
getConnectIds() |
Collection<String> |
getDataInfoIds() |
List<T> |
getDataList() |
Map<String,Map<String,T>> |
getDatas() |
Collection<T> |
getDatas(String dataInfoId) |
SessionServerConfig |
getSessionServerConfig() |
protected abstract Store<T> |
getStore() |
Map<String,T> |
queryByConnectId(ConnectId connectId)
query data by client node connectId
|
Map<ConnectId,Map<String,T>> |
queryByConnectIds(Set<ConnectId> connectIds)
query data by client node connectId
|
T |
queryById(String registerId,
String dataInfoId) |
void |
setSessionServerConfig(SessionServerConfig sessionServerConfig)
Setter method for property sessionServerConfig.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddprotected final Logger logger
@Autowired protected SessionServerConfig sessionServerConfig
public T deleteById(String registerId, String dataInfoId)
DataManagerdeleteById 在接口中 DataManager<T extends BaseInfo,String,String>registerId - registerIddataInfoId - dataInfoIdpublic Map<String,T> deleteByConnectId(ConnectId connectId)
DataManagerdeleteByConnectId 在接口中 DataManager<T extends BaseInfo,String,String>connectId - connectIdpublic Map<ConnectId,Map<String,T>> deleteByConnectIds(Set<ConnectId> connectIds)
DataManagerdeleteByConnectIds 在接口中 DataManager<T extends BaseInfo,String,String>connectIds - connectIdspublic void forEach(java.util.function.BiConsumer<String,Map<String,T>> consumer)
public Collection<T> getDatas(String dataInfoId)
public List<T> getDataList()
getDataList 在接口中 DataManager<T extends BaseInfo,String,String>public Map<String,T> queryByConnectId(ConnectId connectId)
DataManagerqueryByConnectId 在接口中 DataManager<T extends BaseInfo,String,String>connectId - connectIdpublic Map<ConnectId,Map<String,T>> queryByConnectIds(Set<ConnectId> connectIds)
queryByConnectIds 在接口中 DataManager<T extends BaseInfo,String,String>connectIds - connectIdspublic Tuple<Long,Long> count()
DataManagerpublic Set<ConnectId> getConnectIds()
getConnectIds 在接口中 DataManager<T extends BaseInfo,String,String>public Collection<String> getDataInfoIds()
getDataInfoIds 在接口中 DataManager<T extends BaseInfo,String,String>public SessionServerConfig getSessionServerConfig()
public void setSessionServerConfig(SessionServerConfig sessionServerConfig)
sessionServerConfig - value to be assigned to property sessionServerConfigCopyright © 2023 The Ant Financial. All rights reserved.