Uses of Class rice.pastry.messaging.Message (Rice Pastry

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

Rice Pastry API

PREV NEXT

FRAMES NO FRAMES

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.messaging
rice.pastry.multiring
rice.pastry.multiring.messaging
rice.pastry.multiring.testing
rice.pastry.rmi
rice.pastry.routing
rice.pastry.security
rice.pastry.standard
rice.pastry.testing
rice.pastry.wire
rice.rm
rice.rm.messaging
rice.rm.testing
rice.scribe
rice.scribe.maintenance
rice.scribe.messaging
rice.scribe.testing

Uses of Message in rice.pastry

Methods in rice.pastry that return Message

rice.pastry.messaging.Message ScheduledMessage.getMessage()
Returns the message

Methods in rice.pastry with parameters of type Message

void PastryNode.receiveMessage(rice.pastry.messaging.Message msg)
          message receiver interface.

abstract rice.pastry.ScheduledMessage PastryNode.scheduleMsg(rice.pastry.messaging.Message msg, long delay)
          Schedule the specified message to be sent to the local node after a specified delay.

abstract rice.pastry.ScheduledMessage PastryNode.scheduleMsg(rice.pastry.messaging.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 rice.pastry.ScheduledMessage PastryNode.scheduleMsgAtFixedRate(rice.pastry.messaging.Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.

Constructors in rice.pastry with parameters of type Message

ScheduledMessage(rice.pastry.PastryNode pn, rice.pastry.messaging.Message msg)
Constructor

Uses of Message in rice.pastry.client

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

void CommonAPIAppl.route(rice.pastry.Id key, rice.pastry.messaging.Message msg, rice.pastry.NodeHandle hint)
          This operation forwards a message towards the root of key.

abstract void CommonAPIAppl.deliver(rice.pastry.Id key, rice.pastry.messaging.Message msg)
          Called by pastry when a message arrives for this application.

void CommonAPIAppl.messageForAppl(rice.pastry.messaging.Message msg)


void CommonAPIAppl.receiveMessage(rice.pastry.messaging.Message msg)
          Called by pastry to deliver a message to this client.

void PastryAppl.sendMessage(rice.pastry.messaging.Message msg)
          Sends a message directly to the local pastry node.

void PastryAppl.receiveMessage(rice.pastry.messaging.Message msg)
          Called by pastry to deliver a message to this client.

boolean PastryAppl.routeMsgDirect(rice.pastry.NodeHandle dest, rice.pastry.messaging.Message msg, rice.pastry.security.Credentials cred, rice.pastry.routing.SendOptions opt)
          Sends a message to the Pastry node identified by dest.

void PastryAppl.routeMsg(rice.pastry.Id key, rice.pastry.messaging.Message msg, rice.pastry.security.Credentials cred, rice.pastry.routing.SendOptions opt)
          Routes a message to the live node D with nodeId numerically closest to key (at the time of delivery).

abstract void PastryAppl.messageForAppl(rice.pastry.messaging.Message msg)
          Called by pastry when a message arrives for this application.

boolean PastryAppl.enrouteMessage(rice.pastry.messaging.Message msg, rice.pastry.Id key, rice.pastry.NodeId nextHop, rice.pastry.routing.SendOptions opt)
          Called by pastry when a message is enroute and is passing through this node.

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

void PastryEndpoint.messageForAppl(rice.pastry.messaging.Message msg)

void PastryEndpoint.receiveMessage(rice.pastry.messaging.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(rice.pastry.messaging.Message msg)
          DESCRIBE THE METHOD

rice.pastry.ScheduledMessage DirectPastryNode.scheduleMsg(rice.pastry.messaging.Message msg, long delay)
          Schedule the specified message to be sent to the local node after a specified delay.

rice.pastry.ScheduledMessage DirectPastryNode.scheduleMsg(rice.pastry.messaging.Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.

rice.pastry.ScheduledMessage DirectPastryNode.scheduleMsgAtFixedRate(rice.pastry.messaging.Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.

boolean DirectSecurityManager.verifyMessage(rice.pastry.messaging.Message msg)
          This method takes a message and returns true if the message is safe and false otherwise.

void EuclideanNetwork.deliverMessage(rice.pastry.messaging.Message msg, rice.pastry.PastryNode node)
          DESCRIBE THE METHOD

void NetworkSimulator.deliverMessage(rice.pastry.messaging.Message msg, rice.pastry.PastryNode node)
          Deliver message.

void SphereNetwork.deliverMessage(rice.pastry.messaging.Message msg, rice.pastry.PastryNode node)
          DESCRIBE THE METHOD

Uses of Message in rice.pastry.dist

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

void DistNodeHandle.receiveMessage(rice.pastry.messaging.Message message)
          Called to send a message to the node corresponding to this handle.

protected abstract void DistNodeHandle.receiveMessageImpl(rice.pastry.messaging.Message message)
          Called to send a message to the node corresponding to this handle.

rice.pastry.ScheduledMessage DistPastryNode.scheduleMsg(rice.pastry.messaging.Message msg, long delay)
          Schedule the specified message to be sent to the local node after a specified delay.

rice.pastry.ScheduledMessage DistPastryNode.scheduleMsg(rice.pastry.messaging.Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-delay delivery to the local node, beginning after the specified delay.

rice.pastry.ScheduledMessage DistPastryNode.scheduleMsgAtFixedRate(rice.pastry.messaging.Message msg, long delay, long period)
          Schedule the specified message for repeated fixed-rate delivery to the local node, beginning after the specified delay.

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

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

boolean MessageDispatch.dispatchMessage(rice.pastry.messaging.Message msg)
Dispatches a message to the appropriate receiver.

void MessageReceiver.receiveMessage(rice.pastry.messaging.Message msg)
Passes a message along to entity which is this message receiver.

Uses of Message in rice.pastry.multiring

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

void MultiRingAppl.messageForAppl(rice.pastry.messaging.Message msg)


boolean MultiRingMessageDispatch.dispatchMessage(rice.pastry.messaging.Message msg)


void MultiRingPastryNode.processMessage(rice.pastry.messaging.Message msg)


void MultiRingPastryNode.receiveMessage(rice.pastry.messaging.Message m)


rice.pastry.ScheduledMessage MultiRingPastryNode.scheduleMsg(rice.pastry.messaging.Message msg, long delay)


rice.pastry.ScheduledMessage MultiRingPastryNode.scheduleMsg(rice.pastry.messaging.Message msg, long delay, long period)


rice.pastry.ScheduledMessage MultiRingPastryNode.scheduleMsgAtFixedRate(rice.pastry.messaging.Message msg, long delay, long period)

Uses of Message in rice.pastry.multiring.messaging

Subclasses of Message in rice.pastry.multiring.messaging

class MultiRingApplMessage
          Super class for messages used in the multiring appl.

class RingForwardMessage
          A class representing a ring forward request

class RingLookupReminderMessage
          A class representing a ring lookup reminder message

class RingLookupRequestMessage
          A class representing a ring lookup request, which is anycast to the Scribe group rooted at the ringId.

class RingLookupResponseMessage
          A class representing a reponse ring lookup request, which is sent directly to the node which sent the lookup.

Uses of Message in rice.pastry.multiring.testing

Subclasses of Message in rice.pastry.multiring.testing

static class MultiRingPastryRegrTest.MultiRingTestAppMessage

Uses of Message in rice.pastry.rmi

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

void RMINodeHandle.receiveMessageImpl(rice.pastry.messaging.Message msg)
          Called to send a message to the node corresponding to this handle.

void RMINodeHandle.doSend(rice.pastry.messaging.Message msg)
          Do the actual (blocking) RMI call to the remote node

void RMIPastryNode.remoteReceiveMessage(rice.pastry.messaging.Message msg, rice.pastry.NodeId hopDest)
          Proxies to the local node to accept a message.

void RMIPastryNode.enqueueSendMsg(rice.pastry.messaging.Message msg, rice.pastry.rmi.RMINodeHandle handle)
          Enqueues a message for asynchronous transmission

boolean RMIPastrySecurityManager.verifyMessage(rice.pastry.messaging.Message msg)
          This method takes a message and returns true if the message is safe and false otherwise.

void RMIRemoteNodeI.remoteReceiveMessage(rice.pastry.messaging.Message msg, rice.pastry.NodeId hopDest)

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

rice.pastry.messaging.Message RouteMessage.unwrap()
The wrapped message.

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

RouteMessage(rice.pastry.Id target, rice.pastry.messaging.Message msg, rice.pastry.security.Credentials cred)
          Constructor.

RouteMessage(rice.pastry.Id target, rice.pastry.messaging.Message msg, rice.pastry.security.Credentials cred, rice.pastry.routing.SendOptions opts)
          Constructor.

RouteMessage(rice.pastry.NodeHandle dest, rice.pastry.messaging.Message msg, rice.pastry.security.Credentials cred, rice.pastry.routing.SendOptions opts, rice.pastry.messaging.Address aux)
          Constructor.

RouteMessage(rice.pastry.Id target, rice.pastry.messaging.Message msg, rice.pastry.security.Credentials cred, rice.pastry.messaging.Address aux)
          Constructor.

RouteMessage(rice.pastry.Id target, rice.pastry.messaging.Message msg, rice.pastry.security.Credentials cred, rice.pastry.routing.SendOptions opts, rice.pastry.messaging.Address aux)
          Constructor.

RouteMessage(rice.pastry.Id target, rice.pastry.messaging.Message msg, rice.pastry.NodeHandle firstHop, rice.pastry.messaging.Address aux)
          Constructor.

Uses of Message in rice.pastry.security

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

boolean PastrySecurityManager.verifyMessage(rice.pastry.messaging.Message msg)
This method takes a message and returns true if the message is safe and false otherwise.

boolean PermissiveSecurityManager.verifyMessage(rice.pastry.messaging.Message msg)

Uses of Message in rice.pastry.standard

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

void StandardJoinProtocol.receiveMessage(rice.pastry.messaging.Message msg)
          Receives a message from the outside world.

void StandardLeafSetProtocol.receiveMessage(rice.pastry.messaging.Message msg)
          Receives messages.

void StandardRouter.receiveMessage(rice.pastry.messaging.Message msg)
          Receive a message from a remote node.

void StandardRouteSetProtocol.receiveMessage(rice.pastry.messaging.Message msg)
          Receives a message.

Uses of Message in rice.pastry.testing

Subclasses of Message in rice.pastry.testing

class PingMessageNew
PingMessageNew A performance test suite for pastry.

Fields in rice.pastry.testing declared as Message

rice.pastry.messaging.Message PastryRegrTest.lastMsg

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

void HelloWorldApp.messageForAppl(rice.pastry.messaging.Message msg)
          Invoked on destination node when a message arrives.

boolean HelloWorldApp.enrouteMessage(rice.pastry.messaging.Message msg, rice.pastry.Id key, rice.pastry.NodeId nextHop, rice.pastry.routing.SendOptions opt)
          Invoked on intermediate nodes in routing path.

void LeafSetTest.TestNodeHandle.receiveMessage(rice.pastry.messaging.Message m)


void Ping.messageForAppl(rice.pastry.messaging.Message msg)


boolean Ping.enrouteMessage(rice.pastry.messaging.Message msg, rice.pastry.Id from, rice.pastry.NodeId nextHop, rice.pastry.routing.SendOptions opt)


void PingClient.messageForAppl(rice.pastry.messaging.Message msg)


boolean PingClient.enrouteMessage(rice.pastry.messaging.Message msg, rice.pastry.Id from, rice.pastry.NodeId nextHop, rice.pastry.routing.SendOptions opt)


void RegrTestApp.deliver(rice.pastry.Id key, rice.pastry.messaging.Message msg)

Uses of Message in rice.pastry.wire

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

void WireNodeHandle.receiveMessageImpl(rice.pastry.messaging.Message msg)
Called to send a message to the node corresponding to this handle.

boolean WirePastrySecurityManager.verifyMessage(rice.pastry.messaging.Message msg)
This method takes a message and returns true if the message is safe and false otherwise.

Uses of Message in rice.rm

Methods in rice.rm with parameters of type Message

void RMImpl.deliver(rice.pastry.Id key, rice.pastry.messaging.Message msg)
Called by pastry when a message arrives for this application.

Uses of Message in rice.rm.messaging

Subclasses of Message in rice.rm.messaging

class RMMaintenanceMsg


class RMMessage


class RMRequestKeysMsg


class RMResponseKeysMsg


class RMTimeoutMsg

Uses of Message in rice.rm.testing

Subclasses of Message in rice.rm.testing

class DistRMRegrTestMessage
          DistRMRegrTestMessage is used by the dist regression test application on the RM layer to do system invariant checking.

class DistRMRegrTestReplicateMessage
          DistRMRegrTestReplicateMessage is used by the dist regression test application on the RM layer to do the initial replication of a few objects into the system and the periodic refreshing.

class HeartbeatMsg


class InsertMsg


class InsertResponseMsg


class InvariantCheckMsg


class ObjectInsertionMsg


class ObjectRefreshMsg


class RefreshMsg


class ReplicateMsg


class ReplicateResponseMsg


class ReplicateTimeoutMsg


class TestMessage

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

void RMRegrTestApp.deliver(rice.pastry.Id key, rice.pastry.messaging.Message msg)

Uses of Message in rice.scribe

Methods in rice.scribe with parameters of type Message

void Scribe.messageForAppl(rice.pastry.messaging.Message msg)
Called by pastry when a message arrives for this client.

boolean Scribe.enrouteMessage(rice.pastry.messaging.Message msg, rice.pastry.Id target, rice.pastry.NodeId nextHop, rice.pastry.routing.SendOptions opt)
Called by pastry when a message is enroute and is passing through this node.

Uses of Message in rice.scribe.maintenance

Subclasses of Message in rice.scribe.maintenance

class MessageScribeMaintenance
MessageScribeMaintenance is used by a Scribe node to initiate tree maintenance activities for the topics residing on the local node.

Uses of Message in rice.scribe.messaging

Subclasses of Message in rice.scribe.messaging

class MessageAckOnSubscribe


class MessageAnycast
          MessageAnycast is used whenever a Scribe node wishes to anycast to a particular topic.

class MessageCreate
          MessageCreate is used whenever a Scribe node wants to create a new topic.

class MessageHeartBeat
          HeartBeatMessage is used whenever a Scribe nodes wishes let its children know that it is still alive, so that the children need not do any repairing of the multicast tree.

class MessagePublish
          MessagePublish is used whenever a Scribe nodes wishes to send events to a particular topic.

class MessageReplyFromParent
          MessageReplyFromParent is a message sent by the PARENT node to a node as a response to a MessageRequestToParent type of message.

class MessageRequestToParent
          MessageRequestToParent is a message sent by a CHILD node to the PARENT requesting it for the list of topics for which the PARENT node has this node as a CHILD.

class MessageSubscribe
          MessageSubscribe is used whenever a Scribe node wants to subscribe itself to a topic.

class MessageUnsubscribe
          MessageUnsubscribe is used whenever a Scribe node wishes to unsubscribe from a topic.

class ScribeMessage
          This is an abstract implementation of a Scribe message object.

Uses of Message in rice.scribe.testing

Subclasses of Message in rice.scribe.testing

class DirectScribeMaintenanceTest.TestAnycastMessage
A dummy test message used for checking if anycast is doing DFS correctly.

class DistScribeRegrTestMessage
DistScribeRegrTestMessage is used by the dist regression test application on the Scribe layer to do publishing on some topics, etc.

Fields in rice.scribe.testing declared as Message

rice.pastry.messaging.Message BasicScribeRegrTest.m_lastMsg

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

void DistScribeRegrTestApp.messageForAppl(rice.pastry.messaging.Message msg)