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

接口 Registry

所有已知实现类:

SessionRegistry

public interface Registry

版本:

$Id: SessionRegistry.java, v 0.1 2017-11-27 19:49 shangyu.wh Exp $

作者:

shangyu.wh

方法概要

限定符和类型	方法和说明
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
void	register(StoreData<String> data) register new publisher or subscriber data
void	unRegister(StoreData<String> data) message mode com.alipay.sofa.registry.client.provider for client node to unregister single subscriber or publisher data

方法详细资料

register

void register(StoreData<String> data)

register new publisher or subscriber data

参数:

data -

cancel

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

参数:

connectIds -

unRegister

void unRegister(StoreData<String> data)

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

参数:

data -

fetchChangData

void fetchChangData()

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

fetchChangDataProcess

void fetchChangDataProcess()

for fetchChangData first invoke