|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object rice.p2p.scribe.messaging.ScribeMessage rice.p2p.scribe.messaging.AnycastMessage
Field Summary | |
protected RawScribeContent |
content
the content of this message |
protected java.util.LinkedList |
toVisit
the list of nodes which we are going to visit |
static short |
TYPE
DESCRIBE THE FIELD |
protected java.util.Vector |
visited
the list of nodes which we have visited |
Fields inherited from class rice.p2p.scribe.messaging.ScribeMessage |
source, topic |
Fields inherited from interface rice.p2p.commonapi.Message |
HIGH_PRIORITY, LOW_PRIORITY, MAX_PRIORITY, MEDIUM_HIGH_PRIORITY, MEDIUM_LOW_PRIORITY, MEDIUM_PRIORITY |
Constructor Summary | |
protected |
AnycastMessage(InputBuffer buf,
Endpoint endpoint,
ScribeContentDeserializer cd,
boolean readContent)
Protected because it should only be called from an extending class, to get version numbers correct. |
|
AnycastMessage(NodeHandle source,
Topic topic,
RawScribeContent content)
Constructor for AnycastMessage. |
|
AnycastMessage(NodeHandle source,
Topic topic,
ScribeContent content)
Constructor which takes a unique integer Id |
Method Summary | |
void |
addFirst(NodeHandle handle)
Adds a node the the front of the to-visit list |
void |
addLast(NodeHandle handle)
Adds a node the the end of the to-visit list |
void |
addVisited(NodeHandle handle)
Adds a node to the visited list |
static AnycastMessage |
build(InputBuffer buf,
Endpoint endpoint,
ScribeContentDeserializer scd)
DESCRIBE THE METHOD |
ScribeContent |
getContent()
Returns the content |
NodeHandle |
getNext()
Returns the next handle to visit and removes the node from the list. |
short |
getType()
Raw Serialization ************************************** |
NodeHandle |
peekNext()
Returns the next handle to visit |
void |
remove(NodeHandle handle)
Removes the node handle from the to visit and visited lists |
void |
serialize(OutputBuffer buf)
DESCRIBE THE METHOD |
protected void |
serializeHelper(OutputBuffer buf)
Use this to allow SubscribeMessage to extend this, but not have the version number nor the content. |
void |
setContent(RawScribeContent content)
Sets the content |
void |
setContent(ScribeContent content)
Sets the Content attribute of the AnycastMessage object |
Methods inherited from class rice.p2p.scribe.messaging.ScribeMessage |
getPriority, getSource, getTopic, setSource |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected RawScribeContent content
protected java.util.Vector visited
protected java.util.LinkedList toVisit
public static final short TYPE
Constructor Detail |
public AnycastMessage(NodeHandle source, Topic topic, ScribeContent content)
source
- The source addresstopic
- The topiccontent
- The contentpublic AnycastMessage(NodeHandle source, Topic topic, RawScribeContent content)
source
- DESCRIBE THE PARAMETERtopic
- DESCRIBE THE PARAMETERcontent
- DESCRIBE THE PARAMETERprotected AnycastMessage(InputBuffer buf, Endpoint endpoint, ScribeContentDeserializer cd, boolean readContent) throws java.io.IOException
readContent
- should probably be false if this class is extended, true
if not. The parameter is wether or not this message could have a
ScribeContent, the SubscribeMesage never has a content, so it should
be falsebuf
- DESCRIBE THE PARAMETERendpoint
- DESCRIBE THE PARAMETERcd
- DESCRIBE THE PARAMETER
java.io.IOException
- DESCRIBE THE EXCEPTIONMethod Detail |
public ScribeContent getContent()
public NodeHandle getNext()
public short getType()
public void setContent(RawScribeContent content)
content
- The contentpublic void setContent(ScribeContent content)
content
- The new Content valuepublic NodeHandle peekNext()
public void addVisited(NodeHandle handle)
handle
- The node to addpublic void addFirst(NodeHandle handle)
handle
- The handle to addpublic void addLast(NodeHandle handle)
handle
- The handle to addpublic void remove(NodeHandle handle)
handle
- The handle to removepublic void serialize(OutputBuffer buf) throws java.io.IOException
serialize
in interface RawMessage
serialize
in class ScribeMessage
buf
- DESCRIBE THE PARAMETER
java.io.IOException
- DESCRIBE THE EXCEPTIONprotected void serializeHelper(OutputBuffer buf) throws java.io.IOException
buf
- DESCRIBE THE PARAMETER
java.io.IOException
- DESCRIBE THE EXCEPTIONpublic static AnycastMessage build(InputBuffer buf, Endpoint endpoint, ScribeContentDeserializer scd) throws java.io.IOException
buf
- DESCRIBE THE PARAMETERendpoint
- DESCRIBE THE PARAMETERscd
- DESCRIBE THE PARAMETER
java.io.IOException
- DESCRIBE THE EXCEPTION
|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |