Uses of Class
rice.pastry.messaging.Message

Packages that use Message

rice.pastry
rice.pastry.client
rice.pastry.commonapi
rice.pastry.direct
rice.pastry.join
rice.pastry.leafset
rice.pastry.leafset.testing
rice.pastry.messaging
rice.pastry.peerreview
rice.pastry.pns
rice.pastry.pns.messages
rice.pastry.routing
rice.pastry.socket
rice.pastry.socket.nat.probe
rice.pastry.socket.nat.rendezvous
rice.pastry.standard
rice.pastry.testing
rice.pastry.transport

Uses of Message in rice.pastry

Fields in rice.pastry declared as Message

protected Message

ScheduledMessage.msg

Methods in rice.pastry that return Message

Message

ScheduledMessage.getMessage() Returns the message

Methods in rice.pastry with parameters of type Message

void	NodeHandle.bootstrap(Message msg) Method which is used by Pastry to start the bootstrapping process on the local node using this handle as the bootstrap handle.
abstract void	NodeHandle.receiveMessage(Message msg) Deprecated. use PastryNode.send() or Endpoint.send()
void	PastryNode.receiveMessage(Message msg) message receiver interface.
ScheduledMessage	PastryNode.scheduleMsg(Message msg, long delay) Schedule the specified message to be sent to the local node after a specified delay.
ScheduledMessage	PastryNode.scheduleMsg(Message msg, long delay, long period) Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.
ScheduledMessage	PastryNode.scheduleMsgAtFixedRate(Message msg, long delay, long period) Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.
PMessageReceipt	PastryNode.send(NodeHandle handle, Message msg, PMessageNotification deliverAckToMe, java.util.Map<java.lang.String,java.lang.Object> tempOptions) Deliver message to the NodeHandle.

Constructors in rice.pastry with parameters of type Message

ExponentialBackoffScheduledMessage(PastryNode node, Message msg, Timer timer, long initialDelay, double expBase)

ExponentialBackoffScheduledMessage(PastryNode node, Message msg, Timer timer, long initialDelay, long initialPeriod, double expBase, long maxPeriod)

ScheduledMessage(PastryNode pn, Message msg)
Constructor

Uses of Message in rice.pastry.client

Methods in rice.pastry.client with parameters of type Message

abstract void	CommonAPIAppl.deliver(Id key, Message msg) Called by pastry when a message arrives for this application.
boolean	PastryAppl.enrouteMessage(Message msg, Id key, NodeHandle nextHop, SendOptions opt) Called by pastry when a message is enroute and is passing through this node.
void	CommonAPIAppl.messageForAppl(Message msg)
abstract void	PastryAppl.messageForAppl(Message msg) Called by pastry when a message arrives for this application.
void	CommonAPIAppl.receiveMessage(Message msg) Called by pastry to deliver a message to this client.
void	PastryAppl.receiveMessage(Message msg) Called by pastry to deliver a message to this client.
void	CommonAPIAppl.route(Id key, Message msg, NodeHandle hint) This operation forwards a message towards the root of key.
void	PastryAppl.routeMsg(Id key, Message msg, SendOptions opt) Routes a message to the live node D with nodeId numerically closest to key (at the time of delivery).
MessageReceipt	PastryAppl.routeMsg(Id key, Message msg, SendOptions opt, DeliveryNotification deliverAckToMe)
boolean	PastryAppl.routeMsgDirect(NodeHandle dest, Message msg, SendOptions opt) Sends a message to the Pastry node identified by dest.

Uses of Message in rice.pastry.commonapi

Subclasses of Message in rice.pastry.commonapi

class

PastryEndpointMessage This class is an internal message to the commonapi gluecode.

Methods in rice.pastry.commonapi with parameters of type Message

boolean	PastryEndpoint.enrouteMessage(Message msg, Id key, NodeHandle nextHop, SendOptions opt)
void	PastryEndpoint.messageForAppl(Message msg)
void	PastryEndpoint.receiveMessage(Message msg) Called by pastry to deliver a message to this client.

Uses of Message in rice.pastry.direct

Methods in rice.pastry.direct with parameters of type Message

void	DirectNodeHandle.receiveMessage(Message msg) Deprecated. use PastryNode.send()

Uses of Message in rice.pastry.join

Subclasses of Message in rice.pastry.join

class	InitiateJoin Request for the join protocols on the local node to join the overlay.
class	JoinRequest Request to join this network.

Uses of Message in rice.pastry.leafset

Subclasses of Message in rice.pastry.leafset

class	BroadcastLeafSet Broadcast a leaf set to another node.
class	InitiateLeafSetMaintenance Initiate leaf set maintenance on the local node.
class	RequestLeafSet Request a leaf set from another node.

Uses of Message in rice.pastry.leafset.testing

Methods in rice.pastry.leafset.testing with parameters of type Message

void	MergeTest.TestNodeHandle.receiveMessage(Message m) Deprecated.

Uses of Message in rice.pastry.messaging

Subclasses of Message in rice.pastry.messaging

class	PJavaSerializedMessage Wrapper that converts rice.pastry.messaging.Message to rice.pastry.messageing.PRawMessage
class	PRawMessage Adapts Message to a RawMessage Adds the "sender" to the RawMessage

Methods in rice.pastry.messaging that return Message

abstract Message	PJavaSerializedDeserializer.deserialize(InputBuffer buf, short type, int priority, NodeHandle sender)
Message	RawMessageDelivery.deserialize(MessageDeserializer md)
Message	PJavaSerializedMessage.getMessage()

Methods in rice.pastry.messaging with parameters of type Message

boolean	MessageDispatch.dispatchMessage(Message msg) Dispatches a message to the appropriate receiver.
PastryAppl	MessageDispatch.getDestination(Message msg)

Constructors in rice.pastry.messaging with parameters of type Message

PJavaSerializedMessage(Message msg)

Uses of Message in rice.pastry.peerreview

Subclasses of Message in rice.pastry.peerreview

class	FetchLeafsetRequest
class	FetchLeafsetResponse

Methods in rice.pastry.peerreview with parameters of type Message

void	FetchLeafsetApp.messageForAppl(Message msg)

Uses of Message in rice.pastry.pns

Methods in rice.pastry.pns with parameters of type Message

void	PNSApplication.messageForAppl(Message msg)

Uses of Message in rice.pastry.pns.messages

Subclasses of Message in rice.pastry.pns.messages

class	LeafSetRequest
class	LeafSetResponse
class	RouteRowRequest
class	RouteRowResponse

Uses of Message in rice.pastry.routing

Subclasses of Message in rice.pastry.routing

class	BroadcastRouteRow Broadcast message for a row from a routing table.
class	InitiateRouteSetMaintenance Initiate routing table maintenance on the local node
class	RequestRouteRow Request a row from the routing table from another node.
class	RouteMessage A route message contains a pastry message that has been wrapped to be sent to another pastry node.

Fields in rice.pastry.routing declared as Message

Message

RouteMessage.internalMsg

Methods in rice.pastry.routing that return Message

Message	RouteMessage.unwrap() Deprecated. use unwrap(MessageDeserializer)
Message	RouteMessage.unwrap(MessageDeserializer md)

Constructors in rice.pastry.routing with parameters of type Message

RouteMessage(Id target, Message msg, byte serializeVersion)
Constructor.

RouteMessage(Id target, Message msg, NodeHandle firstHop, byte serializeVersion)
Constructor.

RouteMessage(Id target, Message msg, NodeHandle firstHop, SendOptions opts, byte serializeVersion)
Constructor.

RouteMessage(Id target, Message msg, SendOptions opts, byte serializeVersion)
Constructor.

RouteMessage(NodeHandle dest, Message msg, SendOptions opts, byte serializeVersion)
Constructor.

Uses of Message in rice.pastry.socket

Methods in rice.pastry.socket with parameters of type Message

void	SocketNodeHandle.receiveMessage(Message msg) Deprecated. use PastryNode.send(msg, nh)

Uses of Message in rice.pastry.socket.nat.probe

Subclasses of Message in rice.pastry.socket.nat.probe

class

ProbeRequestMessage

Methods in rice.pastry.socket.nat.probe with parameters of type Message

void	ProbeApp.messageForAppl(Message msg)

Uses of Message in rice.pastry.socket.nat.rendezvous

Subclasses of Message in rice.pastry.socket.nat.rendezvous

class	ByteBufferMsg Used to hold a UDP message (usually liveness) when delivering to a firewalled node via Routing.
class	OpenChannelMsg
class	PilotForwardMsg
class	RendezvousJoinRequest Includes the bootstrap (or some other node who will have a pilot from the joiner.)

Methods in rice.pastry.socket.nat.rendezvous with parameters of type Message

void	RendezvousApp.messageForAppl(Message msg) If this is going to cause an infinite loop, just drop the message.

Uses of Message in rice.pastry.standard

Subclasses of Message in rice.pastry.standard

class	ConsistentJoinMsg
class	InitiatePingNeighbor Initiate leaf set maintenance on the local node.

Methods in rice.pastry.standard that return Message

Message	ConsistentJoinProtocol.CJPDeserializer.deserialize(InputBuffer buf, short type, int priority, NodeHandle sender)
Message	PeriodicLeafSetProtocol.PLSPMessageDeserializer.deserialize(InputBuffer buf, short type, int priority, NodeHandle sender)
Message	StandardJoinProtocol.SJPDeserializer.deserialize(InputBuffer buf, short type, int priority, NodeHandle sender)

Methods in rice.pastry.standard with parameters of type Message

void	PeriodicLeafSetProtocol.messageForAppl(Message msg) Should not be called becasue we are overriding the receiveMessage() interface anyway.
void	StandardJoinProtocol.messageForAppl(Message msg) Should not be called becasue we are overriding the receiveMessage() interface anyway.
void	StandardLeafSetProtocol.messageForAppl(Message msg) Receives messages.
void	StandardRouteSetProtocol.messageForAppl(Message msg) Receives a message.
void	StandardRouter.messageForAppl(Message msg)
void	ConsistentJoinProtocol.receiveMessage(Message msg) Handle the CJM as in the MSR-TR
void	PeriodicLeafSetProtocol.receiveMessage(Message msg) Receives messages.
void	StandardJoinProtocol.receiveMessage(Message msg) Receives a message from the outside world.
void	StandardRouter.receiveMessage(Message msg) Receive a message from a remote node.

Uses of Message in rice.pastry.testing

Subclasses of Message in rice.pastry.testing

class	HelloMsg
class	PingMessageNew PingMessageNew A performance test suite for pastry.

Fields in rice.pastry.testing declared as Message

Message

PastryRegrTest.lastMsg

Methods in rice.pastry.testing with parameters of type Message

void	RegrTestApp.deliver(Id key, Message msg) Makes sure the message was delivered to the correct node by crossrefrencing the sorted nodes list in the simulator.
boolean	HelloWorldApp.enrouteMessage(Message msg, Id key, NodeHandle nextHop, SendOptions opt) Invoked on intermediate nodes in routing path.
boolean	Ping.enrouteMessage(Message msg, Id from, NodeHandle nextHop, SendOptions opt)
boolean	PingClient.enrouteMessage(Message msg, Id from, NodeHandle nextHop, SendOptions opt)
void	HelloWorldApp.messageForAppl(Message msg) Invoked on destination node when a message arrives.
void	Ping.messageForAppl(Message msg)
void	PingClient.messageForAppl(Message msg)
void	LeafSetTest.TestNodeHandle.receiveMessage(Message m) Deprecated.

Uses of Message in rice.pastry.transport

Methods in rice.pastry.transport that return Message

Message	PMessageReceipt.getMessage()
Message	PMessageReceiptImpl.getMessage()

Methods in rice.pastry.transport with parameters of type Message

void	BogusNodeHandle.receiveMessage(Message msg)

Constructors in rice.pastry.transport with parameters of type Message

PMessageReceiptImpl(Message msg, java.util.Map<java.lang.String,java.lang.Object> options)