Uses of Class
rice.pastry.messaging.Message

Packages that use Message

rice.pastry
rice.pastry.client
rice.pastry.commonapi
rice.pastry.direct
rice.pastry.dist
rice.pastry.join
rice.pastry.leafset
rice.pastry.leafset.testing
rice.pastry.messaging
rice.pastry.routing
rice.pastry.socket
rice.pastry.socket.messaging
rice.pastry.standard
rice.pastry.testing

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.
abstract ScheduledMessage	PastryNode.scheduleMsg(Message msg, long delay) Schedule the specified message to be sent to the local node after a specified delay.
abstract 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.
abstract 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.
abstract void	PastryNode.send(NodeHandle handle, Message message) 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 delay, long initialPeriod, double expBase)

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).
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

ScheduledMessage	BasicNetworkSimulator.deliverMessage(Message msg, DirectPastryNode node) node should always be a local node, because this will be delivered instantly
ScheduledMessage	NetworkSimulator.deliverMessage(Message msg, DirectPastryNode node) Deliver message ASAP.
ScheduledMessage	BasicNetworkSimulator.deliverMessage(Message msg, DirectPastryNode node, int delay)
ScheduledMessage	NetworkSimulator.deliverMessage(Message msg, DirectPastryNode node, int delay) Deliver message.
ScheduledMessage	BasicNetworkSimulator.deliverMessage(Message msg, DirectPastryNode node, int delay, int period)
ScheduledMessage	NetworkSimulator.deliverMessage(Message msg, DirectPastryNode node, int delay, int period) Deliver message.
ScheduledMessage	BasicNetworkSimulator.deliverMessageFixedRate(Message msg, DirectPastryNode node, int delay, int period)
ScheduledMessage	NetworkSimulator.deliverMessageFixedRate(Message msg, DirectPastryNode node, int delay, int period) Deliver message.
void	BasicNetworkSimulator.notifySimulatorListeners(Message m, NodeHandle from, NodeHandle to, int delay)
void	NetworkSimulator.notifySimulatorListeners(Message m, NodeHandle from, NodeHandle to, int delay) Call this when a message is sent.
void	DirectNodeHandle.receiveMessage(Message msg) Deprecated. use PastryNode.send()
void	DirectPastryNode.receiveMessage(Message msg)
ScheduledMessage	DirectPastryNode.scheduleMsg(Message msg, long delay) Schedule the specified message to be sent to the local node after a specified delay.
ScheduledMessage	DirectPastryNode.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	DirectPastryNode.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.
void	DirectPastryNode.send(NodeHandle nh, Message m)

Uses of Message in rice.pastry.dist

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

ScheduledMessage	DistPastryNode.scheduleMsg(Message msg, long delay) Schedule the specified message to be sent to the local node after a specified delay.
ScheduledMessage	DistPastryNode.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	DistPastryNode.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.
ExponentialBackoffScheduledMessage	DistPastryNode.scheduleMsgExpBackoff(Message msg, long delay, long initialPeriod, double expBase)

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.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.

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)
Constructor.

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

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

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

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

Uses of Message in rice.pastry.socket

Subclasses of Message in rice.pastry.socket

class

SourceRoute Class which represets a source route to a remote IP address.

Methods in rice.pastry.socket that return Message

Message	SocketBuffer.deserialize(MessageDeserializer md)
protected Message	SocketPastryNodeFactory.getResponse(java.net.InetSocketAddress address, Message message) This method anonymously sends the given message to the remote address, blocks until a response is received, and then closes the socket and returns the response.

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

void	SocketSourceRouteManager.bootstrap(EpochInetSocketAddress address, Message msg) Method which sends a bootstrap message across the wire.
void	SocketNodeHandle.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.
void	SocketCollectionManager.bootstrap(SourceRoute path, Message message) Method which sends bootstraps a node by sending message across the wire, using a fake IP address in the header so that the local node is not marked alive, and then closes the connection.
boolean	SocketChannelWriter.enqueue(Message msg)
protected Message	SocketPastryNodeFactory.getResponse(java.net.InetSocketAddress address, Message message) This method anonymously sends the given message to the remote address, blocks until a response is received, and then closes the socket and returns the response.
protected CancellableTask	SocketPastryNodeFactory.getResponse(java.net.InetSocketAddress address, Message message, Continuation c)
void	SocketNodeHandle.receiveMessage(Message msg) Deprecated. use PastryNode.send(msg, nh)
void	SocketSourceRouteManager.send(EpochInetSocketAddress address, Message msg)
void	SocketPastryNode.send(NodeHandle handle, Message message)

Uses of Message in rice.pastry.socket.messaging

Subclasses of Message in rice.pastry.socket.messaging

class	DatagramMessage Class which represents a "ping" message sent through the socket pastry system.
class	IPAddressRequestMessage Class which represents a request for the external visible IP address
class	IPAddressResponseMessage Class which represents a request for the external visible IP address
class	LeafSetRequestMessage Message which represents a request to get the leafset from the remote node.
class	LeafSetResponseMessage A response message to a LeafSetRequestMessage, containing the remote node's leafset.
class	NodeIdRequestMessage Message which represents a request to get a node Id from the remote node.
class	NodeIdResponseMessage A response message to a NodeIdRequestMessage, containing the remote node's nodeId.
class	PingMessage Class which represents a "ping" message sent through the socket pastry system.
class	PingResponseMessage Class which represents a "ping" message sent through the socket pastry system.
class	RouteRowRequestMessage Message which represents a request to get the leafset from the remote node.
class	RouteRowResponseMessage A response message to a RouteRowRequestMessage, containing the remote node's routerow.
class	RoutesRequestMessage Message which represents a request to get the leafset from the remote node.
class	RoutesResponseMessage A response message to a RoutesRequestMessage, containing the remote node's routes.
class	SocketMessage Class which represents an abstract control message
class	WrongEpochMessage Class which represents a "ping" message sent through the socket pastry system.

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

PeriodicLeafSetProtocol.PLSPMessageDeserializer.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.