|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.tomp2p.message.Message
public class Message
The message is in binary format in TomP2P. It is defined as follows and has several header and payload fields. Since we do the serialization manually, we do not need a serialization field.
Nested Class Summary | |
---|---|
static class |
Message.Command
|
static class |
Message.Content
|
static class |
Message.Type
|
Constructor Summary | |
---|---|
Message()
Creates message with a random ID |
Method Summary | |
---|---|
void |
finished()
|
SimpleBloomFilter<Number160> |
getBloomFilter1()
|
SimpleBloomFilter<Number160> |
getBloomFilter2()
|
Message.Command |
getCommand()
Command of the message, such as GET, PING, etc. |
Message.Content |
getContentType1()
Returns first content type. |
Message.Content |
getContentType2()
Returns second content type, only if first is not empty |
Message.Content |
getContentType3()
Returns second content type, only if first is not empty |
Message.Content |
getContentType4()
Returns second content type, only if first is not empty |
Map<Number160,Data> |
getDataMap()
|
long |
getFinished()
|
Map<Number160,HashData> |
getHashDataMap()
|
int |
getInteger()
|
Number160 |
getKey()
|
Number160 |
getKeyKey1()
|
Number160 |
getKeyKey2()
|
Map<Number160,Number160> |
getKeyMap()
|
Collection<Number160> |
getKeys()
|
Collection<Number480> |
getKeysConvert()
|
long |
getLength()
The length of the payload |
long |
getLong()
|
int |
getMessageId()
Randomly generated message ID |
Collection<PeerAddress> |
getNeighbors()
Returns the stored neighbors |
int |
getOptions()
|
org.jboss.netty.buffer.ChannelBuffer |
getPayload1()
|
org.jboss.netty.buffer.ChannelBuffer |
getPayload2()
|
PublicKey |
getPublicKey()
|
PeerAddress |
getRecipient()
The ID of the recipient. |
PeerAddress |
getSender()
The ID of the sender. |
Collection<TrackerData> |
getTrackerData()
|
Message.Type |
getType()
Determines if its a request oCommandr reply, and what kind of reply (error, warning states) |
int |
getVersion()
Returns the version, which is 32bit. |
boolean |
hasContent()
|
boolean |
isConvertNumber480to160()
|
boolean |
isError()
|
static boolean |
isError(Message.Type type)
|
boolean |
isFireAndForget()
|
boolean |
isHintSign()
|
boolean |
isKeepAlive()
|
boolean |
isNotOk()
|
boolean |
isOk()
|
boolean |
isRequest()
|
boolean |
isUDP()
|
Message |
setCommand(Message.Command command)
Command of the message, such as GET, PING, etc. |
Message |
setContentType(Message.Content contentType)
Convient method to set content type. |
void |
setConvertNumber480to160(boolean convertNumber480to160)
|
Message |
setDataMap(Map<Number160,Data> dataMap)
|
Message |
setDataMapConvert(Map<Number480,Data> dataMap)
|
Message |
setHashDataMap(Map<Number160,HashData> hashDataMap)
|
void |
setHintSign(boolean hintSign)
|
Message |
setInteger(int int_number)
|
void |
setKeepAlive(boolean isKeepAlive)
|
Message |
setKey(Number160 key3)
|
Message |
setKeyKey(Number160 key1,
Number160 key2)
|
Message |
setKeyMap(Map<Number160,Number160> keyMap)
|
Message |
setKeys(Collection<Number160> keys)
|
Message |
setKeysConvert(Collection<Number480> keysConvert)
|
Message |
setLength(long length)
Set payload length. |
Message |
setLong(long long_number)
|
Message |
setMessageId(int messageId)
For deserialization, we need to set the id |
Message |
setNeighbors(Collection<PeerAddress> neighbors)
|
Message |
setNeighbors(Collection<PeerAddress> neighbors,
int useAtMostNeighbors)
|
void |
setOptions(int options)
|
Message |
setPayload(org.jboss.netty.buffer.ChannelBuffer payload)
|
Message |
setPublicKey(PublicKey publicKey)
|
Message |
setPublicKeyAndSign(KeyPair keyPair)
|
Message |
setRecipient(PeerAddress recipient)
Set the ID of the recipient. |
Message |
setSender(PeerAddress sender)
The ID of the sender. |
void |
setTCP()
|
Message |
setTrackerData(Collection<TrackerData> trackerData)
|
Message |
setTwoBloomFilter(SimpleBloomFilter<Number160> bloomFilter1,
SimpleBloomFilter<Number160> bloomFilter2)
|
Message |
setType(Message.Type type)
Set the message type. |
void |
setUDP()
|
Message |
setVersion(int version)
For deserialization |
String |
toString()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public Message()
Method Detail |
---|
public int getMessageId()
public Message setMessageId(int messageId)
messageId
- The message Idpublic void setUDP()
public void setTCP()
public boolean isUDP()
public void finished()
public long getFinished()
public int getVersion()
public Message setVersion(int version)
version
- The 24bit versionpublic Message.Type getType()
public Message setType(Message.Type type)
type
- Type of the messagepublic Message.Command getCommand()
public Message setCommand(Message.Command command)
command
- Commandpublic PeerAddress getSender()
public Message setSender(PeerAddress sender)
sender
- The ID of the sender.public PeerAddress getRecipient()
public Message setRecipient(PeerAddress recipient)
recipient
- The ID of the recipientpublic long getLength()
public Message setLength(long length)
contentLength
- The length of the payloadpublic Message.Content getContentType1()
public Message.Content getContentType2()
public Message.Content getContentType3()
public Message.Content getContentType4()
public Message setContentType(Message.Content contentType)
contentType
- public boolean isRequest()
public boolean isFireAndForget()
public boolean isOk()
public boolean isNotOk()
public boolean isError()
public static boolean isError(Message.Type type)
public Message setNeighbors(Collection<PeerAddress> neighbors)
public Message setNeighbors(Collection<PeerAddress> neighbors, int useAtMostNeighbors)
public Collection<PeerAddress> getNeighbors()
public Message setKeysConvert(Collection<Number480> keysConvert)
public Message setKeys(Collection<Number160> keys)
public Collection<Number160> getKeys()
public Collection<Number480> getKeysConvert()
public Message setDataMapConvert(Map<Number480,Data> dataMap)
public Message setDataMap(Map<Number160,Data> dataMap)
public Map<Number160,Data> getDataMap()
public Message setKey(Number160 key3)
public Message setKeyKey(Number160 key1, Number160 key2)
public Number160 getKeyKey1()
public Number160 getKeyKey2()
public Number160 getKey()
public Message setKeyMap(Map<Number160,Number160> keyMap)
public Map<Number160,Number160> getKeyMap()
public Message setLong(long long_number)
public long getLong()
public Message setPayload(org.jboss.netty.buffer.ChannelBuffer payload)
public org.jboss.netty.buffer.ChannelBuffer getPayload1()
public org.jboss.netty.buffer.ChannelBuffer getPayload2()
public Message setInteger(int int_number)
public int getInteger()
public PublicKey getPublicKey()
public Message setPublicKey(PublicKey publicKey)
public Message setPublicKeyAndSign(KeyPair keyPair)
public void setHintSign(boolean hintSign)
public boolean isHintSign()
public Message setTrackerData(Collection<TrackerData> trackerData)
public Collection<TrackerData> getTrackerData()
public void setConvertNumber480to160(boolean convertNumber480to160)
public boolean isConvertNumber480to160()
public boolean hasContent()
public void setOptions(int options)
public int getOptions()
public void setKeepAlive(boolean isKeepAlive)
public boolean isKeepAlive()
public String toString()
toString
in class Object
public Message setHashDataMap(Map<Number160,HashData> hashDataMap)
public Map<Number160,HashData> getHashDataMap()
public Message setTwoBloomFilter(SimpleBloomFilter<Number160> bloomFilter1, SimpleBloomFilter<Number160> bloomFilter2)
public SimpleBloomFilter<Number160> getBloomFilter1()
public SimpleBloomFilter<Number160> getBloomFilter2()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |