|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.alibaba.dubbo.remoting.exchange.support.ExchangeServerDelegate
com.alibaba.dubbo.remoting.p2p.exchange.support.ExchangeServerPeer
public class ExchangeServerPeer
ServerPeer
Constructor Summary | |
---|---|
ExchangeServerPeer(ExchangeServer server,
Map<URL,ExchangeClient> clients,
ExchangeGroup group)
|
Method Summary | |
---|---|
void |
close()
close the channel. |
Channel |
getChannel(InetSocketAddress remoteAddress)
get channel. |
Collection<Channel> |
getChannels()
get channels. |
ExchangeChannel |
getExchangeChannel(InetSocketAddress remoteAddress)
get channel. |
Collection<ExchangeChannel> |
getExchangeChannels()
get channels. |
void |
leave()
leave. |
void |
send(Object message)
send message. |
void |
send(Object message,
boolean sent)
send message. |
Methods inherited from class com.alibaba.dubbo.remoting.exchange.support.ExchangeServerDelegate |
---|
close, getChannelHandler, getLocalAddress, getServer, getUrl, isBound, isClosed, reset, reset, setServer, startClose |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface com.alibaba.dubbo.remoting.Server |
---|
isBound, reset |
Methods inherited from interface com.alibaba.dubbo.remoting.Endpoint |
---|
close, getChannelHandler, getLocalAddress, getUrl, isClosed, startClose |
Methods inherited from interface com.alibaba.dubbo.common.Resetable |
---|
reset |
Constructor Detail |
---|
public ExchangeServerPeer(ExchangeServer server, Map<URL,ExchangeClient> clients, ExchangeGroup group)
Method Detail |
---|
public void leave() throws RemotingException
Peer
leave
in interface Peer
RemotingException
public void close()
Endpoint
close
in interface Endpoint
close
in class ExchangeServerDelegate
public Collection<Channel> getChannels()
Server
getChannels
in interface Server
getChannels
in class ExchangeServerDelegate
public Channel getChannel(InetSocketAddress remoteAddress)
Server
getChannel
in interface Server
getChannel
in class ExchangeServerDelegate
public Collection<ExchangeChannel> getExchangeChannels()
ExchangeServer
getExchangeChannels
in interface ExchangeServer
getExchangeChannels
in class ExchangeServerDelegate
public ExchangeChannel getExchangeChannel(InetSocketAddress remoteAddress)
ExchangeServer
getExchangeChannel
in interface ExchangeServer
getExchangeChannel
in class ExchangeServerDelegate
public void send(Object message) throws RemotingException
Endpoint
send
in interface Endpoint
send
in class ExchangeServerDelegate
RemotingException
public void send(Object message, boolean sent) throws RemotingException
Endpoint
send
in interface Endpoint
send
in class ExchangeServerDelegate
sent
- 是否已发送完成
RemotingException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |