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

类 FetchPubSubDataInfoIdService

java.lang.Object

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

public class FetchPubSubDataInfoIdService
extends Object

版本:

: FetchPubSubDataInfoIdService.java, v 0.1 2021年08月04日 11:05 xiaojian.xj Exp $

作者:

xiaojian.xj

字段概要

字段

限定符和类型	字段和说明
protected DataStore	sessionDataStore store publishers
protected Interests	sessionInterests store subscribers

构造器概要

构造器

构造器和说明
FetchPubSubDataInfoIdService()

方法概要

限定符和类型	方法和说明
protected Map<String,Set<String>>	parsePubDataInfoIds(Map<ConnectId,Map<String,Publisher>> connectIdPubMap)
protected Map<String,Set<String>>	parseSubDataInfoIds(Map<ConnectId,Map<String,Subscriber>> connectIdSubMap)
PubSubDataInfoIdResp	queryByIps(Set<String> ips)

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

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

字段详细资料

sessionInterests

@Autowired
protected Interests sessionInterests

store subscribers

sessionDataStore

@Autowired
protected DataStore sessionDataStore

store publishers

构造器详细资料

FetchPubSubDataInfoIdService

public FetchPubSubDataInfoIdService()

方法详细资料

queryByIps

public PubSubDataInfoIdResp queryByIps(Set<String> ips)

parsePubDataInfoIds

protected Map<String,Set<String>> parsePubDataInfoIds(Map<ConnectId,Map<String,Publisher>> connectIdPubMap)

parseSubDataInfoIds

protected Map<String,Set<String>> parseSubDataInfoIds(Map<ConnectId,Map<String,Subscriber>> connectIdSubMap)