com.alipay.sofa.registry.server.session.store

类 SessionInterests

java.lang.Object

com.alipay.sofa.registry.server.session.store.AbstractDataManager<Subscriber>

com.alipay.sofa.registry.server.session.store.SessionInterests

所有已实现的接口:

DataManager<Subscriber,String,String>, Interests

public class SessionInterests
extends AbstractDataManager<Subscriber>
implements Interests

版本:

$Id: AbstractSessionInterests.java, v 0.1 2017-11-30 20:42 shangyu.wh Exp $

作者:

shangyu.wh

嵌套类概要

从接口继承的嵌套类/接口 com.alipay.sofa.registry.server.session.store.Interests

Interests.InterestVersionCheck

字段概要

从类继承的字段 com.alipay.sofa.registry.server.session.store.AbstractDataManager

logger, sessionServerConfig

构造器概要

构造器

构造器和说明
SessionInterests()

方法概要

限定符和类型	方法和说明
boolean	add(Subscriber subscriber) new publisher and subscriber data add
Interests.InterestVersionCheck	checkInterestVersion(String dataCenter, String datumDataInfoId, long version) check subscribers interest dataInfoId version,very dataCenter dataInfoId version different if return false else check return bigger version
Map<String,List<String>>	filterIPs(String group, int limit)
Collection<Subscriber>	getInterests(String datumDataInfoId)
protected Store<Subscriber>	getStore()
SessionRegistry.SelectSubscriber	selectSubscribers(Set<String> dataCenters)

从类继承的方法 com.alipay.sofa.registry.server.session.store.AbstractDataManager

addData, count, deleteByConnectId, deleteByConnectIds, deleteById, forEach, getConnectIds, getDataInfoIds, getDataList, getDatas, getDatas, getSessionServerConfig, queryByConnectId, queryByConnectIds, queryById, setSessionServerConfig

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.alipay.sofa.registry.server.session.store.DataManager

count, deleteByConnectId, deleteByConnectIds, deleteById, forEach, getConnectIds, getDataInfoIds, getDataList, getDatas, getDatas, queryByConnectId, queryByConnectIds, queryById

构造器详细资料

SessionInterests

public SessionInterests()

方法详细资料

add

public boolean add(Subscriber subscriber)

从接口复制的说明: DataManager

new publisher and subscriber data add

指定者:

add 在接口中 DataManager<Subscriber,String,String>

参数:

subscriber - data

返回:

boolean

checkInterestVersion

public Interests.InterestVersionCheck checkInterestVersion(String dataCenter,
                                                           String datumDataInfoId,
                                                           long version)

从接口复制的说明: Interests

check subscribers interest dataInfoId version,very dataCenter dataInfoId version different if return false else check return bigger version

指定者:

checkInterestVersion 在接口中 Interests

参数:

dataCenter - dataCenter

datumDataInfoId - datumDataInfoId

version - version

返回:

InterestVersionCheck

getInterests

public Collection<Subscriber> getInterests(String datumDataInfoId)

指定者:

getInterests 在接口中 Interests

selectSubscribers

public SessionRegistry.SelectSubscriber selectSubscribers(Set<String> dataCenters)

指定者:

selectSubscribers 在接口中 Interests

getStore

protected Store<Subscriber> getStore()

指定者:

getStore 在类中 AbstractDataManager<Subscriber>

filterIPs

public Map<String,List<String>> filterIPs(String group,
                                          int limit)

指定者:

filterIPs 在接口中 Interests