|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Message in rice.p2p.aggregation |
---|
Methods in rice.p2p.aggregation with parameters of type Message | |
---|---|
void |
AggregationImpl.deliver(Id id,
Message message)
|
Uses of Message in rice.p2p.aggregation.messaging |
---|
Classes in rice.p2p.aggregation.messaging that implement Message | |
---|---|
class |
AggregationMessage
|
class |
AggregationTimeoutMessage
|
Uses of Message in rice.p2p.commonapi |
---|
Methods in rice.p2p.commonapi that return Message | |
---|---|
Message |
RouteMessage.getMessage()
Deprecated. use getMesage(MessageDeserializer) |
Message |
RouteMessage.getMessage(MessageDeserializer md)
|
Methods in rice.p2p.commonapi with parameters of type Message | |
---|---|
void |
Application.deliver(Id id,
Message message)
This method is called on the application at the destination node for the given id. |
void |
Endpoint.route(Id id,
Message message,
NodeHandle hint)
This method makes an attempt to route the message to the root of the given id. |
CancellableTask |
Endpoint.scheduleMessage(Message message,
long delay)
Schedules a message to be delivered to this application after the provided number of milliseconds. |
CancellableTask |
Endpoint.scheduleMessage(Message message,
long delay,
long period)
Schedules a message to be delivered to this application every period number of milliseconds, after delay number of miliseconds have passed. |
CancellableTask |
Endpoint.scheduleMessageAtFixedRate(Message message,
long delay,
long period)
Schedules a message to be delivered to this application every period number of milliseconds, after delay number of miliseconds have passed. |
void |
RouteMessage.setMessage(Message message)
Sets the internal message for this message |
Uses of Message in rice.p2p.commonapi.rawserialization |
---|
Subinterfaces of Message in rice.p2p.commonapi.rawserialization | |
---|---|
interface |
RawMessage
|
Methods in rice.p2p.commonapi.rawserialization that return Message | |
---|---|
Message |
MessageDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
RawMessage ret = super.deserialize(); if (ret != null) return ret; Endpoint endpoint; switch(type) { case 1: return new MyMessage(buf, endpoint); } |
Uses of Message in rice.p2p.glacier.v2 |
---|
Methods in rice.p2p.glacier.v2 with parameters of type Message | |
---|---|
void |
GlacierImpl.deliver(Id id,
Message message)
|
Uses of Message in rice.p2p.glacier.v2.messaging |
---|
Classes in rice.p2p.glacier.v2.messaging that implement Message | |
---|---|
class |
GlacierDataMessage
|
class |
GlacierFetchMessage
|
class |
GlacierMessage
|
class |
GlacierNeighborRequestMessage
|
class |
GlacierNeighborResponseMessage
|
class |
GlacierQueryMessage
DESCRIBE THE CLASS |
class |
GlacierRangeForwardMessage
|
class |
GlacierRangeQueryMessage
|
class |
GlacierRangeResponseMessage
|
class |
GlacierRefreshCompleteMessage
|
class |
GlacierRefreshPatchMessage
|
class |
GlacierRefreshProbeMessage
|
class |
GlacierRefreshResponseMessage
|
class |
GlacierResponseMessage
|
class |
GlacierSyncMessage
|
class |
GlacierTimeoutMessage
|
Uses of Message in rice.p2p.multiring |
---|
Methods in rice.p2p.multiring that return Message | |
---|---|
Message |
MultiringRouteMessage.getMessage()
Deprecated. Use getMessages(MessageDeserializer) |
Message |
MultiringRouteMessage.getMessage(MessageDeserializer md)
|
Methods in rice.p2p.multiring with parameters of type Message | |
---|---|
void |
MultiringApplication.deliver(Id id,
Message message)
This method is called on the application at the destination node for the given id. |
protected void |
MultiringEndpoint.deliver(RingId id,
Message target)
Internal method which delivers the message to the application |
void |
MultiringEndpoint.route(Id id,
Message message,
NodeHandle hint)
This method makes an attempt to route the message to the root of the given id. |
CancellableTask |
MultiringEndpoint.scheduleMessage(Message message,
long delay)
Schedules a message to be delivered to this application after the provided number of milliseconds. |
CancellableTask |
MultiringEndpoint.scheduleMessage(Message message,
long delay,
long period)
Schedules a message to be delivered to this application every period number of milliseconds, after delay number of miliseconds have passed. |
CancellableTask |
MultiringEndpoint.scheduleMessageAtFixedRate(Message message,
long delay,
long period)
|
void |
MultiringRouteMessage.setMessage(Message message)
Sets the internal message for this message |
Uses of Message in rice.p2p.multiring.messaging |
---|
Methods in rice.p2p.multiring.messaging that return Message | |
---|---|
Message |
RingMessage.getMessage()
|
Uses of Message in rice.p2p.multiring.testing |
---|
Classes in rice.p2p.multiring.testing that implement Message | |
---|---|
static class |
MultiringRegrTest.MultiringTestMessage
|
Methods in rice.p2p.multiring.testing with parameters of type Message | |
---|---|
void |
MultiringRegrTest.MultiringTestApp.deliver(Id id,
Message message)
|
Uses of Message in rice.p2p.past |
---|
Methods in rice.p2p.past that return Message | |
---|---|
Message |
PastImpl.PastDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Methods in rice.p2p.past with parameters of type Message | |
---|---|
void |
PastImpl.deliver(Id id,
Message message)
This method is called on the application at the destination node for the given id. |
Uses of Message in rice.p2p.past.gc |
---|
Methods in rice.p2p.past.gc that return Message | |
---|---|
Message |
GCPastImpl.GCPastDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Methods in rice.p2p.past.gc with parameters of type Message | |
---|---|
void |
GCPastImpl.deliver(Id id,
Message message)
This method is called on the application at the destination node for the given id. |
void |
GCEndpoint.route(Id id,
Message message,
NodeHandle hint)
This method makes an attempt to route the message to the root of the given id. |
CancellableTask |
GCEndpoint.scheduleMessage(Message message,
long delay)
Schedules a message to be delivered to this application after the provided number of milliseconds. |
CancellableTask |
GCEndpoint.scheduleMessage(Message message,
long delay,
long period)
Schedules a message to be delivered to this application every period number of milliseconds, after delay number of miliseconds have passed. |
CancellableTask |
GCEndpoint.scheduleMessageAtFixedRate(Message message,
long delay,
long period)
|
Uses of Message in rice.p2p.past.gc.messaging |
---|
Classes in rice.p2p.past.gc.messaging that implement Message | |
---|---|
class |
GCCollectMessage
|
class |
GCInsertMessage
|
class |
GCLookupHandlesMessage
|
class |
GCRefreshMessage
|
Uses of Message in rice.p2p.past.messaging |
---|
Classes in rice.p2p.past.messaging that implement Message | |
---|---|
class |
CacheMessage
|
class |
ContinuationMessage
|
class |
FetchHandleMessage
|
class |
FetchMessage
|
class |
InsertMessage
|
class |
LookupHandlesMessage
|
class |
LookupMessage
|
class |
MessageLostMessage
|
class |
PastMessage
|
Constructors in rice.p2p.past.messaging with parameters of type Message | |
---|---|
MessageLostMessage(int uid,
NodeHandle local,
Id id,
Message message,
NodeHandle hint)
Constructor which takes a unique integer Id and the local id |
Uses of Message in rice.p2p.past.testing |
---|
Methods in rice.p2p.past.testing that return Message | |
---|---|
Message |
PastRegrTest.TestRouteMessage.getMessage()
Deprecated. |
Message |
RawPastRegrTest.TestRouteMessage.getMessage()
Deprecated. |
Message |
PastRegrTest.TestRouteMessage.getMessage(MessageDeserializer md)
|
Message |
RawPastRegrTest.TestRouteMessage.getMessage(MessageDeserializer md)
|
Methods in rice.p2p.past.testing with parameters of type Message | |
---|---|
void |
PastRegrTest.TestRouteMessage.setMessage(Message message)
|
void |
RawPastRegrTest.TestRouteMessage.setMessage(Message message)
|
Constructors in rice.p2p.past.testing with parameters of type Message | |
---|---|
PastRegrTest.TestRouteMessage(Id id,
NodeHandle nextHop,
Message message)
|
|
RawPastRegrTest.TestRouteMessage(Id id,
NodeHandle nextHop,
Message message)
|
Uses of Message in rice.p2p.replication |
---|
Methods in rice.p2p.replication with parameters of type Message | |
---|---|
void |
ReplicationImpl.deliver(Id id,
Message message)
This method is called on the application at the destination node for the given id. |
Uses of Message in rice.p2p.replication.manager |
---|
Methods in rice.p2p.replication.manager with parameters of type Message | |
---|---|
void |
ReplicationManagerImpl.deliver(Id id,
Message message)
This method is called on the application at the destination node for the given id. |
Uses of Message in rice.p2p.replication.manager.messaging |
---|
Classes in rice.p2p.replication.manager.messaging that implement Message | |
---|---|
class |
ReminderMessage
|
class |
TimeoutMessage
|
Uses of Message in rice.p2p.replication.messaging |
---|
Classes in rice.p2p.replication.messaging that implement Message | |
---|---|
class |
ReplicationMessage
|
class |
RequestMessage
|
class |
ResponseMessage
|
Uses of Message in rice.p2p.scribe |
---|
Methods in rice.p2p.scribe with parameters of type Message | |
---|---|
void |
ScribeImpl.deliver(Id id,
Message message)
This method is called on the application at the destination node for the given id. |
Uses of Message in rice.p2p.scribe.messaging |
---|
Classes in rice.p2p.scribe.messaging that implement Message | |
---|---|
class |
AbstractSubscribeMessage
|
class |
AnycastMessage
|
class |
DropMessage
|
class |
MaintenanceMessage
|
class |
PublishMessage
|
class |
PublishRequestMessage
|
class |
ScribeMessage
|
class |
SubscribeAckMessage
|
class |
SubscribeFailedMessage
|
class |
SubscribeLostMessage
|
class |
SubscribeMessage
|
class |
UnsubscribeMessage
|
Uses of Message in rice.p2p.scribe.testing |
---|
Methods in rice.p2p.scribe.testing that return Message | |
---|---|
Message |
RawScribeRegrTest.TestRouteMessage.getMessage()
Deprecated. |
Message |
ScribeRegrTest.TestRouteMessage.getMessage()
Deprecated. |
Message |
RawScribeRegrTest.TestRouteMessage.getMessage(MessageDeserializer md)
|
Message |
ScribeRegrTest.TestRouteMessage.getMessage(MessageDeserializer md)
|
Methods in rice.p2p.scribe.testing with parameters of type Message | |
---|---|
void |
RawScribeRegrTest.TestRouteMessage.setMessage(Message message)
Sets the Message attribute of the TestRouteMessage object |
void |
ScribeRegrTest.TestRouteMessage.setMessage(Message message)
Sets the Message attribute of the TestRouteMessage object |
Constructors in rice.p2p.scribe.testing with parameters of type Message | |
---|---|
RawScribeRegrTest.TestRouteMessage(Id id,
NodeHandle nextHop,
Message message)
Constructor for TestRouteMessage. |
|
ScribeRegrTest.TestRouteMessage(Id id,
NodeHandle nextHop,
Message message)
Constructor for TestRouteMessage. |
Uses of Message in rice.p2p.util.rawserialization |
---|
Classes in rice.p2p.util.rawserialization that implement Message | |
---|---|
class |
JavaSerializedMessage
Wrapper that converts rice.pastry.messaging.Message to rice.pastry.messageing.PRawMessage |
Methods in rice.p2p.util.rawserialization that return Message | |
---|---|
Message |
JavaSerializedDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Message |
JavaSerializedMessage.getMessage()
|
Methods in rice.p2p.util.rawserialization with parameters of type Message | |
---|---|
static void |
JavaSerializer.serialize(Message msg,
OutputBuffer buf)
|
Constructors in rice.p2p.util.rawserialization with parameters of type Message | |
---|---|
JavaSerializedMessage(Message msg)
|
Uses of Message in rice.pastry.commonapi |
---|
Classes in rice.pastry.commonapi that implement Message | |
---|---|
class |
PastryEndpointMessage
This class is an internal message to the commonapi gluecode. |
Methods in rice.pastry.commonapi that return Message | |
---|---|
Message |
PastryEndpointMessage.getMessage()
Returns the internal message |
Methods in rice.pastry.commonapi with parameters of type Message | |
---|---|
void |
PastryEndpoint.route(Id key,
Message msg,
NodeHandle hint)
This operation forwards a message towards the root of key. |
CancellableTask |
PastryEndpoint.scheduleMessage(Message message,
long delay)
Schedules a message to be delivered to this application after the provided number of milliseconds. |
CancellableTask |
PastryEndpoint.scheduleMessage(Message message,
long delay,
long period)
Schedules a message to be delivered to this application every period number of milliseconds, after delay number of miliseconds have passed. |
CancellableTask |
PastryEndpoint.scheduleMessageAtFixedRate(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 |
PastryEndpointMessage.setMessage(Message message)
Returns the internal message |
Constructors in rice.pastry.commonapi with parameters of type Message | |
---|---|
PastryEndpointMessage(int address,
Message message,
NodeHandle sender)
Constructor. |
Uses of Message in rice.pastry.direct |
---|
Methods in rice.pastry.direct with parameters of type Message | |
---|---|
void |
SimulatorListener.messageSent(Message m,
NodeHandle from,
NodeHandle to,
int delay)
Called for every message sent over the network. |
Uses of Message in rice.pastry.join |
---|
Classes in rice.pastry.join that implement Message | |
---|---|
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 |
---|
Classes in rice.pastry.leafset that implement Message | |
---|---|
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 |
---|
Classes in rice.pastry.messaging that implement Message | |
---|---|
class |
Message
This is an abstract implementation of a message object. |
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 | |
---|---|
Message |
JavaSerializedDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Message |
PJavaSerializedDeserializer.deserialize(InputBuffer buf,
short type,
int priority,
NodeHandle sender)
|
Uses of Message in rice.pastry.routing |
---|
Classes in rice.pastry.routing that implement Message | |
---|---|
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.getMessage()
Deprecated. use getMessage(MessageDeserializer) |
Message |
RouteMessage.getMessage(MessageDeserializer md)
|
Methods in rice.pastry.routing with parameters of type Message | |
---|---|
void |
RouteMessage.setMessage(Message message)
|
Uses of Message in rice.pastry.socket |
---|
Classes in rice.pastry.socket that implement Message | |
---|---|
class |
SourceRoute
Class which represets a source route to a remote IP address. |
Uses of Message in rice.pastry.socket.appsocket.testing |
---|
Methods in rice.pastry.socket.appsocket.testing with parameters of type Message | |
---|---|
void |
Echo.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.pastry.socket.messaging |
---|
Classes in rice.pastry.socket.messaging that implement Message | |
---|---|
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 |
---|
Classes in rice.pastry.standard that implement Message | |
---|---|
class |
ConsistentJoinMsg
|
class |
InitiatePingNeighbor
Initiate leaf set maintenance on the local node. |
Uses of Message in rice.pastry.testing |
---|
Classes in rice.pastry.testing that implement Message | |
---|---|
class |
HelloMsg
|
class |
PingMessageNew
PingMessageNew A performance test suite for pastry. |
Methods in rice.pastry.testing with parameters of type Message | |
---|---|
void |
RoutingTableTest.MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.appsocket |
---|
Methods in rice.tutorial.appsocket with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.direct |
---|
Classes in rice.tutorial.direct that implement Message | |
---|---|
class |
MyMsg
An example message. |
Methods in rice.tutorial.direct with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.forwarding |
---|
Methods in rice.tutorial.forwarding with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.gtitm |
---|
Methods in rice.tutorial.gtitm with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.lesson3 |
---|
Methods in rice.tutorial.lesson3 with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.lesson4 |
---|
Methods in rice.tutorial.lesson4 with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.lesson5 |
---|
Methods in rice.tutorial.lesson5 with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.lesson6 |
---|
Methods in rice.tutorial.lesson6 with parameters of type Message | |
---|---|
void |
MyScribeClient.deliver(Id id,
Message message)
Part of the Application interface. |
Uses of Message in rice.tutorial.rawserialization |
---|
Methods in rice.tutorial.rawserialization with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.rawserialization2 |
---|
Methods in rice.tutorial.rawserialization2 with parameters of type Message | |
---|---|
void |
MyApp.deliver(Id id,
Message message)
Called when we receive a message. |
Uses of Message in rice.tutorial.splitstream |
---|
Methods in rice.tutorial.splitstream with parameters of type Message | |
---|---|
void |
MySplitStreamClient.deliver(Id id,
Message message)
Part of the Application interface. |
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |