public class SessionInterests extends Object implements Interests, ReSubscribers
| 构造器和说明 |
|---|
SessionInterests() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
add(Subscriber subscriber)
new publisher and subscriber data add
|
void |
addReSubscriber(Subscriber subscriber) |
boolean |
checkAndUpdateInterestVersions(String dataCenter,
String dataInfoId,
Long version)
check subscribers interest dataInfoId version,very dataCenter dataInfoId version different
if not exist add
else check and update big version
|
boolean |
checkInterestVersions(String dataCenter,
String dataInfoId,
Long version)
check subscribers interest dataInfoId version,very dataCenter dataInfoId version different
if return false
else check return bigger version
|
void |
clearReSubscribers() |
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
|
boolean |
deleteReSubscriber(Subscriber subscriber) |
Collection<String> |
getInterestDataInfoIds()
get all subscriber dataInfoIds
|
Collection<Subscriber> |
getInterests(String dataInfoId)
query subscribers by dataInfoID
|
Map<String,Map<String,Subscriber>> |
getReSubscribers() |
SessionServerConfig |
getSessionServerConfig() |
Map<String,Subscriber> |
queryByConnectId(String connectId)
query data by client node connectId
|
Subscriber |
queryById(String registerId,
String dataInfoId)
get subscriber by dataInfoId and registerId
|
Map<InetSocketAddress,Map<String,Subscriber>> |
querySubscriberIndex(String dataInfoId,
com.alipay.sofa.registry.core.model.ScopeEnum scope)
get subscribers whith specify dataInfo and scope,and group by source InetSocketAddress
|
void |
setSessionServerConfig(SessionServerConfig sessionServerConfig)
Setter method for property sessionServerConfig.
|
public void add(Subscriber subscriber)
DataManageradd 在接口中 DataManager<Subscriber,String,String>public boolean deleteById(String registerId, String dataInfoId)
DataManagerdeleteById 在接口中 DataManager<Subscriber,String,String>public boolean deleteByConnectId(String connectId)
DataManagerdeleteByConnectId 在接口中 DataManager<Subscriber,String,String>public long count()
DataManagercount 在接口中 DataManager<Subscriber,String,String>public Map<String,Subscriber> queryByConnectId(String connectId)
DataManagerqueryByConnectId 在接口中 DataManager<Subscriber,String,String>public Subscriber queryById(String registerId, String dataInfoId)
Interestspublic Collection<Subscriber> getInterests(String dataInfoId)
InterestsgetInterests 在接口中 Interestspublic boolean checkInterestVersions(String dataCenter, String dataInfoId, Long version)
InterestscheckInterestVersions 在接口中 Interestspublic boolean checkAndUpdateInterestVersions(String dataCenter, String dataInfoId, Long version)
InterestscheckAndUpdateInterestVersions 在接口中 Interestspublic Collection<String> getInterestDataInfoIds()
InterestsgetInterestDataInfoIds 在接口中 Interestspublic Map<InetSocketAddress,Map<String,Subscriber>> querySubscriberIndex(String dataInfoId, com.alipay.sofa.registry.core.model.ScopeEnum scope)
InterestsquerySubscriberIndex 在接口中 Interestspublic void addReSubscriber(Subscriber subscriber)
addReSubscriber 在接口中 ReSubscriberspublic boolean deleteReSubscriber(Subscriber subscriber)
deleteReSubscriber 在接口中 ReSubscriberspublic Map<String,Map<String,Subscriber>> getReSubscribers()
getReSubscribers 在接口中 ReSubscriberspublic void clearReSubscribers()
clearReSubscribers 在接口中 ReSubscriberspublic SessionServerConfig getSessionServerConfig()
public void setSessionServerConfig(SessionServerConfig sessionServerConfig)
sessionServerConfig - value to be assigned to property sessionServerConfigCopyright © 2019 The Ant Financial. All rights reserved.