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

接口 Interests

所有超级接口:

DataManager<Subscriber,String,String>

所有已知实现类:

SessionInterests

public interface Interests
extends DataManager<Subscriber,String,String>

版本:

$Id: SessionInterests.java, v 0.1 2017-11-30 15:53 shangyu.wh Exp $

作者:

shangyu.wh

方法概要

限定符和类型	方法和说明
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
Collection<String>	getInterestDataInfoIds() get all subscriber dataInfoIds
Collection<Subscriber>	getInterests(String dataInfoId) query subscribers by dataInfoID
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

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

add, count, deleteByConnectId, deleteById, queryByConnectId

方法详细资料

getInterests

Collection<Subscriber> getInterests(String dataInfoId)

query subscribers by dataInfoID

参数:

dataInfoId -

返回:

checkInterestVersions

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

参数:

dataCenter -

dataInfoId -

version -

返回:

checkAndUpdateInterestVersions

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

参数:

dataCenter -

dataInfoId -

version -

返回:

getInterestDataInfoIds

Collection<String> getInterestDataInfoIds()

get all subscriber dataInfoIds

返回:

querySubscriberIndex

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

参数:

dataInfoId -

scope -

返回:

queryById

Subscriber queryById(String registerId,
                     String dataInfoId)

get subscriber by dataInfoId and registerId

参数:

registerId -

dataInfoId -

返回: