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

类 DataNodeNotifyExchanger

java.lang.Object

com.alipay.sofa.registry.server.shared.remoting.ClientSideExchanger

com.alipay.sofa.registry.server.session.remoting.DataNodeNotifyExchanger

所有已实现的接口:

NodeExchanger, EventListener, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextRefreshedEvent>

public class DataNodeNotifyExchanger
extends ClientSideExchanger

use for dataNode notify

作者:

yuzhi.lyz

字段概要

从类继承的字段 com.alipay.sofa.registry.server.shared.remoting.ClientSideExchanger

boltExchange, serverIps, serverType

构造器概要

构造器

构造器和说明
DataNodeNotifyExchanger()

方法概要

限定符和类型	方法和说明
Client	connectServer()
protected Collection<ChannelHandler>	getClientHandlers()
int	getConnNum()
int	getRpcTimeoutMillis()
int	getServerPort()
Response	request(Request request)

从类继承的方法 com.alipay.sofa.registry.server.shared.remoting.ClientSideExchanger

connect, getClient, getConnections, getServerIps, init, notifyConnectServerAsync, onApplicationEvent, requestRaw, setBoltExchange, setServerIps, tryConnectAllServer

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

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

构造器详细资料

DataNodeNotifyExchanger

public DataNodeNotifyExchanger()

方法详细资料

request

public Response request(Request request)
                 throws RequestException

指定者:

request 在接口中 NodeExchanger

覆盖:

request 在类中 ClientSideExchanger

抛出:

RequestException

另请参阅:

request(Request)

connectServer

public Client connectServer()

指定者:

connectServer 在接口中 NodeExchanger

覆盖:

connectServer 在类中 ClientSideExchanger

getClientHandlers

protected Collection<ChannelHandler> getClientHandlers()

指定者:

getClientHandlers 在类中 ClientSideExchanger

getRpcTimeoutMillis

public int getRpcTimeoutMillis()

指定者:

getRpcTimeoutMillis 在类中 ClientSideExchanger

getServerPort

public int getServerPort()

指定者:

getServerPort 在类中 ClientSideExchanger

getConnNum

public int getConnNum()

覆盖:

getConnNum 在类中 ClientSideExchanger