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

类 SessionRegistry

java.lang.Object

com.alipay.sofa.registry.server.session.registry.SessionRegistry

所有已实现的接口:

Registry

public class SessionRegistry
extends Object
implements Registry

版本:

$Id: AbstractSessionRegistry.java, v 0.1 2017-11-30 18:13 shangyu.wh Exp $

作者:

shangyu.wh

构造器概要

构造器

构造器和说明
SessionRegistry()

方法概要

限定符和类型	方法和说明
void	cancel(List<String> connectIds) cancel publisher or subscriber data by client ip address and port(ip:port),one ip address has more than one processId when disconnection between client node and session node,disconnect event fire remove all pub and sub info on session and data node this function always use in Console manage Client node list,input ip list must transform to connectId through connect manage
void	fetchChangData() Timing tasks to send all subscriber dataInfoId version to data, Select higher version data push to client node
void	fetchChangDataProcess() for fetchChangData first invoke
DataStore	getSessionDataStore() Getter method for property sessionDataStore.
Interests	getSessionInterests() Getter method for property sessionInterests.
TaskListenerManager	getTaskListenerManager() Getter method for property taskListenerManager.
void	register(StoreData storeData) register new publisher or subscriber data
void	unRegister(StoreData<String> storeData) message mode com.alipay.sofa.registry.client.provider for client node to unregister single subscriber or publisher data

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

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

构造器详细资料

SessionRegistry

public SessionRegistry()

方法详细资料

register

public void register(StoreData storeData)

从接口复制的说明: Registry

register new publisher or subscriber data

指定者:

register 在接口中 Registry

unRegister

public void unRegister(StoreData<String> storeData)

从接口复制的说明: Registry

message mode com.alipay.sofa.registry.client.provider for client node to unregister single subscriber or publisher data

指定者:

unRegister 在接口中 Registry

cancel

public void cancel(List<String> connectIds)

从接口复制的说明: Registry

cancel publisher or subscriber data by client ip address and port(ip:port),one ip address has more than one processId when disconnection between client node and session node,disconnect event fire remove all pub and sub info on session and data node this function always use in Console manage Client node list,input ip list must transform to connectId through connect manage

指定者:

cancel 在接口中 Registry

fetchChangData

public void fetchChangData()

从接口复制的说明: Registry

Timing tasks to send all subscriber dataInfoId version to data, Select higher version data push to client node

指定者:

fetchChangData 在接口中 Registry

fetchChangDataProcess

public void fetchChangDataProcess()

从接口复制的说明: Registry

for fetchChangData first invoke

指定者:

fetchChangDataProcess 在接口中 Registry

getSessionInterests

public Interests getSessionInterests()

Getter method for property sessionInterests.

返回:

property value of sessionInterests

getSessionDataStore

public DataStore getSessionDataStore()

Getter method for property sessionDataStore.

返回:

property value of sessionDataStore

getTaskListenerManager

public TaskListenerManager getTaskListenerManager()

Getter method for property taskListenerManager.

返回:

property value of taskListenerManager