Uses of Class
net.tomp2p.message.Message

Packages that use Message

net.tomp2p.connection
net.tomp2p.futures
net.tomp2p.message
net.tomp2p.rpc

Uses of Message in net.tomp2p.connection

Methods in net.tomp2p.connection with parameters of type Message

void	SenderNetty.sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator)
void	Sender.sendBroadcastUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator) Sent the message via UDP broadcast.
void	SenderNetty.sendTCP(RequestHandlerTCP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator, int idleTCPMillis)
void	Sender.sendTCP(RequestHandlerTCP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator, int idleTCPMillis) Sent the message via TCP.
void	SenderNetty.sendUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator)
void	Sender.sendUDP(RequestHandlerUDP<? extends BaseFuture> handler, FutureResponse futureResponse, Message message, ChannelCreator channelCreator) Sent the message via UDP.

Uses of Message in net.tomp2p.futures

Methods in net.tomp2p.futures that return Message

Message	FutureResponse.getRequest() The future response always keeps a reference to the request.
Message	FutureResponse.getResponse() Returns the response message.

Methods in net.tomp2p.futures with parameters of type Message

BaseFuture.FutureType	FutureSuccessEvaluatorCommunication.evaluate(Message requestMessage, Message responseMessage)
BaseFuture.FutureType	FutureSuccessEvaluatorOperation.evaluate(Message requestMessage, Message responseMessage)
BaseFuture.FutureType	FutureSuccessEvaluator.evaluate(Message requestMessage, Message responseMessage)
void	FutureResponse.setResponse(Message responseMessage) Gets called if a peer responds.

Constructors in net.tomp2p.futures with parameters of type Message

FutureResponse(Message requestMessage)
Create the future and set the request message

FutureResponse(Message requestMessage, boolean raw)

FutureResponse(Message requestMessage, FutureSuccessEvaluator futureSuccessEvaluator)

FutureResponse(Message requestMessage, FutureSuccessEvaluator futureSuccessEvaluator, boolean raw)
Create the future and set the request message

Uses of Message in net.tomp2p.message

Methods in net.tomp2p.message that return Message

protected Message	TomP2PDecoderUDP.decode(org.jboss.netty.channel.ChannelHandlerContext ctx, org.jboss.netty.channel.Channel channel, org.jboss.netty.buffer.ChannelBuffer buffer, SocketAddress socketAddress)
static Message	MessageCodec.decodeHeader(org.jboss.netty.buffer.ChannelBuffer buffer, InetSocketAddress recipient, InetSocketAddress sender) Decode a message header from a Netty buffer
Message	Message.replaceDataMap(Map<Number480,Data> dataMap480)
Message	Message.setCommand(Message.Command command) Command of the message, such as GET, PING, etc.
Message	Message.setContentType(Message.Content contentType) Convient method to set content type.
Message	Message.setDataMap(Map<Number160,Data> dataMap)
Message	Message.setDataMap480(Map<Number480,Data> dataMap480)
Message	Message.setDataMapConvert(Map<Number480,Data> dataMap480)
Message	Message.setHashDataMap(Map<Number160,HashData> hashDataMap)
Message	Message.setInteger(int int_number)
Message	Message.setKey(Number160 key3)
Message	Message.setKeyKey(Number160 key1, Number160 key2)
Message	Message.setKeyMap(Map<Number160,Number160> keyMap)
Message	Message.setKeys(Collection<Number160> keys)
Message	Message.setKeys480(Collection<Number480> keys480)
Message	Message.setKeysConvert(Collection<Number480> keys480)
Message	Message.setLength(long length) Set payload length.
Message	Message.setLong(long long_number)
Message	Message.setMessageId(int messageId) For deserialization, we need to set the id
Message	Message.setNeighbors(Collection<PeerAddress> neighbors)
Message	Message.setNeighbors(Collection<PeerAddress> neighbors, int useAtMostNeighbors)
Message	Message.setPayload(org.jboss.netty.buffer.ChannelBuffer payload)
Message	Message.setPublicKey(PublicKey publicKey)
Message	Message.setPublicKeyAndSign(KeyPair keyPair)
Message	Message.setRecipient(PeerAddress recipient) Set the ID of the recipient.
Message	Message.setSender(PeerAddress sender) The ID of the sender.
Message	Message.setTrackerData(Collection<TrackerData> trackerData)
Message	Message.setTwoBloomFilter(SimpleBloomFilter<Number160> bloomFilter1, SimpleBloomFilter<Number160> bloomFilter2)
Message	Message.setType(Message.Type type) Set the message type.
Message	Message.setVersion(int version) For deserialization

Methods in net.tomp2p.message with parameters of type Message

static boolean	MessageCodec.decodePayload(Message.Content content, org.jboss.netty.buffer.ChannelBuffer buffer, Message message) Decodes the payload from a Netty buffer in a big switch
static boolean	MessageCodec.decodeSignature(Signature signature, Message message, org.jboss.netty.buffer.ChannelBuffer buffer)
static org.jboss.netty.buffer.ChannelBuffer	MessageCodec.encodeHeader(org.jboss.netty.buffer.ChannelBuffer buffer, Message message) The format looks as follows: 32bit p2p version - 32bit id - 4bit message type - 4bit message name - 160bit sender id - 16bit tcp port - 16bit udp port - 160bit recipient id - 16bit (4x4)content type - 8bit network address information.
static void	MessageCodec.encodePayload(Message message, ProtocolChunkedInput input) Encode payload

Constructors in net.tomp2p.message with parameters of type Message

MessageID(Message message)
Creates a message Id.

Uses of Message in net.tomp2p.rpc

Methods in net.tomp2p.rpc that return Message

Message	ReplyHandler.createMessage(PeerAddress recipient, Message.Command name, Message.Type type)
Message	ReplyHandler.createResponseMessage(Message message, Message.Type type)
Message	ReplyHandler.forwardMessage(Message message)
Message	StorageRPC.handleResponse(Message message, boolean sign)
Message	TaskRPC.handleResponse(Message message, boolean sign)
abstract Message	ReplyHandler.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.
Message	NeighborRPC.handleResponse(Message message, boolean sign)
Message	PeerExchangeRPC.handleResponse(Message message, boolean sign)
Message	BroadcastRPC.handleResponse(Message message, boolean sign)
Message	DirectDataRPC.handleResponse(Message message, boolean sign)
Message	QuitRPC.handleResponse(Message message, boolean sign)
Message	TrackerRPC.handleResponse(Message message, boolean sign)
Message	HandshakeRPC.handleResponse(Message message, boolean sign)

Methods in net.tomp2p.rpc with parameters of type Message

Message	ReplyHandler.createResponseMessage(Message message, Message.Type type)
Message	ReplyHandler.forwardMessage(Message message)
Message	StorageRPC.handleResponse(Message message, boolean sign)
Message	TaskRPC.handleResponse(Message message, boolean sign)
abstract Message	ReplyHandler.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.
Message	NeighborRPC.handleResponse(Message message, boolean sign)
Message	PeerExchangeRPC.handleResponse(Message message, boolean sign)
Message	BroadcastRPC.handleResponse(Message message, boolean sign)
Message	DirectDataRPC.handleResponse(Message message, boolean sign)
Message	QuitRPC.handleResponse(Message message, boolean sign)
Message	TrackerRPC.handleResponse(Message message, boolean sign)
Message	HandshakeRPC.handleResponse(Message message, boolean sign)

Constructors in net.tomp2p.rpc with parameters of type Message

RequestHandlerTCP(K futureResponse, PeerBean peerBean, ConnectionBean connectionBean, Message message)

RequestHandlerUDP(K futureResponse, PeerBean peerBean, ConnectionBean connectionBean, Message message)