public class BroadcastRPC extends ReplyHandler
Constructor and Description |
---|
BroadcastRPC(PeerBean peerBean,
ConnectionBean connectionBean,
BroadcastHandler broadcastHandler) |
Modifier and Type | Method and Description |
---|---|
BroadcastHandler |
getBroadcastHandler() |
Message |
handleResponse(Message message,
boolean sign)
If the message is OK, that has been previously checked by the user using
checkMessage, a reply to the message is generated here.
|
FutureResponse |
send(PeerAddress remotePeer,
Number160 messageKey,
Map<Number160,Data> dataMap,
ChannelCreator channelCreator,
int idleTCPMillis,
boolean forceUDP) |
FutureResponse |
send(PeerAddress remotePeer,
Number160 messageKey,
Map<Number160,Data> dataMap,
int hopCounter,
ChannelCreator channelCreator,
int idleTCPMillis,
boolean forceUDP) |
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 BroadcastRPC(PeerBean peerBean, ConnectionBean connectionBean, BroadcastHandler broadcastHandler)
public FutureResponse send(PeerAddress remotePeer, Number160 messageKey, Map<Number160,Data> dataMap, ChannelCreator channelCreator, int idleTCPMillis, boolean forceUDP)
public FutureResponse send(PeerAddress remotePeer, Number160 messageKey, Map<Number160,Data> dataMap, int hopCounter, ChannelCreator channelCreator, int idleTCPMillis, boolean forceUDP)
public Message handleResponse(Message message, boolean sign) throws Exception
ReplyHandler
handleResponse
in class ReplyHandler
message
- Request messageException
public BroadcastHandler getBroadcastHandler()
Copyright © 2013. All Rights Reserved.