public class HandshakeRPC extends ReplyHandler
Constructor and Description |
---|
HandshakeRPC(PeerBean peerBean,
ConnectionBean connectionBean) |
HandshakeRPC(PeerBean peerBean,
ConnectionBean connectionBean,
List<PeerListener> listeners) |
createMessage, createResponseMessage, exceptionCaught, forwardMessage, getConnectionBean, getPeerBean, registerIoHandler, setSignReply
bindRequested, channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, handleDownstream, handleUpstream, messageReceived, setInterestOpsRequested, unbindRequested, writeComplete, writeRequested
public HandshakeRPC(PeerBean peerBean, ConnectionBean connectionBean)
public HandshakeRPC(PeerBean peerBean, ConnectionBean connectionBean, List<PeerListener> listeners)
public FutureResponse pingBroadcastUDP(PeerAddress remotePeer, ChannelCreator channelCreator)
public RequestHandlerUDP<FutureResponse> pingUDP(PeerAddress remotePeer)
public RequestHandlerTCP<FutureResponse> pingTCP(PeerAddress remotePeer)
public FutureResponse pingUDP(PeerAddress remotePeer, ChannelCreator channelCreator)
public FutureResponse pingTCP(PeerAddress remotePeer, ChannelCreator channelCreator)
public FutureResponse fireUDP(PeerAddress remotePeer, ChannelCreator channelCreator)
public FutureResponse fireTCP(PeerAddress remotePeer, ChannelCreator channelCreator)
public FutureResponse pingUDPDiscover(PeerAddress remotePeer, ChannelCreator channelCreator)
public FutureResponse pingTCPDiscover(PeerAddress remotePeer, ChannelCreator channelCreator)
public FutureResponse pingUDPProbe(PeerAddress remotePeer, ChannelCreator channelCreator)
public FutureResponse pingTCPProbe(PeerAddress remotePeer, ChannelCreator channelCreator)
public Message handleResponse(Message message, boolean sign) throws Exception
ReplyHandler
handleResponse
in class ReplyHandler
message
- Request messageException
Copyright © 2013. All Rights Reserved.