net.tomp2p.rpc
Class NeighborRPC
java.lang.Object
org.jboss.netty.channel.SimpleChannelHandler
net.tomp2p.rpc.ReplyHandler
net.tomp2p.rpc.NeighborRPC
- All Implemented Interfaces:
- org.jboss.netty.channel.ChannelDownstreamHandler, org.jboss.netty.channel.ChannelHandler, org.jboss.netty.channel.ChannelUpstreamHandler
public class NeighborRPC
- extends ReplyHandler
Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler |
org.jboss.netty.channel.ChannelHandler.Sharable |
Method Summary |
boolean |
checkMessage(Message message)
Before a reply can be done, the message needs to be checked. |
FutureResponse |
closeNeighbors(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Command command,
boolean isDigest,
boolean forceTCP,
ChannelCreator channelCreator)
Deprecated. |
FutureResponse |
closeNeighbors(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Command command,
boolean isDigest,
ChannelCreator channelCreator,
boolean forceTCP)
Requests close neighbors from the remote peer. |
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. |
Methods inherited from class org.jboss.netty.channel.SimpleChannelHandler |
bindRequested, channelBound, channelClosed, channelConnected, channelDisconnected, channelInterestChanged, channelOpen, channelUnbound, childChannelClosed, childChannelOpen, closeRequested, connectRequested, disconnectRequested, handleDownstream, handleUpstream, messageReceived, setInterestOpsRequested, unbindRequested, writeComplete, writeRequested |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
NEIGHBOR_SIZE
public static final int NEIGHBOR_SIZE
- See Also:
- Constant Field Values
NeighborRPC
public NeighborRPC(PeerBean peerBean,
ConnectionBean connectionBean)
closeNeighbors
@Deprecated
public FutureResponse closeNeighbors(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Command command,
boolean isDigest,
boolean forceTCP,
ChannelCreator channelCreator)
- Deprecated.
closeNeighbors
public FutureResponse closeNeighbors(PeerAddress remotePeer,
Number160 locationKey,
Number160 domainKey,
Collection<Number160> contentKeys,
Message.Command command,
boolean isDigest,
ChannelCreator channelCreator,
boolean forceTCP)
- Requests close neighbors from the remote peer. The remote peer may
idicate if the data is present on that peer. This is an RPC.
- Parameters:
remotePeer
- The remote peer to send this requestlocationKey
- The location keydomainKey
- The domain keycontentKeys
- For get() and remove() one can provide the content
keys and the remote peer indicates if those keys are on that peer.command
- either Command.NEIGHBORS_TRACKER or
Command.NEIGHBORS_STORAGEisDigest
- Set to true to return a digest of the remote contentchannelCreator
- The channel creator that creates connectionsforceTCP
- Set to true if the communication should be TCP, default
is UDP
- Returns:
- The future response to keep track of future events
checkMessage
public boolean checkMessage(Message message)
- Description copied from class:
ReplyHandler
- Before a reply can be done, the message needs to be checked. If you
return false, then the peer is removed from the map and the channel is
closed.
- Specified by:
checkMessage
in class ReplyHandler
- Parameters:
message
- Request message
- Returns:
- True if a request should be generated, false if channel should be
closed and nothing should be replied
handleResponse
public Message handleResponse(Message message,
boolean sign)
throws IOException
- Description copied from class:
ReplyHandler
- If the message is OK, that has been previously checked by the user using
checkMessage, a reply to the message is generated here.
- Specified by:
handleResponse
in class ReplyHandler
- Parameters:
message
- Request message
- Throws:
IOException
Copyright © 2012. All Rights Reserved.