|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of ScribeContent in org.mpisws.p2p.testing.transportlayer.replay |
---|
Classes in org.mpisws.p2p.testing.transportlayer.replay that implement ScribeContent | |
---|---|
class |
MyScribeContent
|
Methods in org.mpisws.p2p.testing.transportlayer.replay with parameters of type ScribeContent | |
---|---|
boolean |
MyScribeClient.anycast(Topic topic,
ScribeContent content)
Called when we receive an anycast. |
void |
MyScribeClient.deliver(Topic topic,
ScribeContent content)
Called whenever we receive a published message. |
Uses of ScribeContent in rice.p2p.multiring |
---|
Methods in rice.p2p.multiring with parameters of type ScribeContent | |
---|---|
boolean |
MultiringNode.anycast(Topic topic,
ScribeContent content)
This method is invoked when an anycast is received for a topic which this client is interested in. |
void |
MultiringNode.deliver(Topic topic,
ScribeContent content)
This method is invoked when a message is delivered for a topic this client is interested in. |
Uses of ScribeContent in rice.p2p.multiring.messaging |
---|
Classes in rice.p2p.multiring.messaging that implement ScribeContent | |
---|---|
class |
RingMessage
|
Uses of ScribeContent in rice.p2p.scribe |
---|
Methods in rice.p2p.scribe that return ScribeContent | |
---|---|
ScribeContent |
ScribePolicy.divideContent(java.util.List<Topic> theTopics,
ScribeContent content)
This method is called when the ScribeImpl splits a SubscribeMessage into multiple parts. |
ScribeContent |
ScribePolicy.DefaultScribePolicy.divideContent(java.util.List<Topic> theTopics,
ScribeContent content)
|
Methods in rice.p2p.scribe with parameters of type ScribeContent | |
---|---|
java.util.List<Topic> |
ScribePolicy.allowSubscribe(Scribe scribe,
NodeHandle source,
java.util.List<Topic> topics,
ScribeContent content)
This method is called when the newChild is about to become our child, and the policy should return whether or not the child should be allowed to become our child. |
java.util.List<Topic> |
ScribePolicy.DefaultScribePolicy.allowSubscribe(Scribe scribe,
NodeHandle source,
java.util.List<Topic> topics,
ScribeContent content)
If you don't override the deprecated allowSubscribe(), This method always return true; |
boolean |
ScribeClient.anycast(Topic topic,
ScribeContent content)
Deprecated. This method is invoked when an anycast is received for a topic which this client is interested in. |
void |
ScribeImpl.anycast(Topic topic,
ScribeContent content)
Anycasts the given content to a member of the given topic |
boolean |
ScribeImpl.ScribeClientConverter.anycast(Topic topic,
ScribeContent content)
|
boolean |
ScribeMultiClient.anycast(Topic topic,
ScribeContent content)
This method is invoked when an anycast is received for a topic which this client is interested in. |
void |
ScribeImpl.anycast(Topic topic,
ScribeContent content,
NodeHandle hint)
|
protected RawScribeContent |
ScribeImpl.convert(ScribeContent content)
|
void |
ScribeClient.deliver(Topic topic,
ScribeContent content)
Deprecated. This method is invoked when a message is delivered for a topic this client is interested in. |
void |
ScribeImpl.ScribeClientConverter.deliver(Topic topic,
ScribeContent content)
|
void |
ScribeMultiClient.deliver(Topic topic,
ScribeContent content)
This method is invoked when a message is delivered for a topic this client is interested in. |
ScribeContent |
ScribePolicy.divideContent(java.util.List<Topic> theTopics,
ScribeContent content)
This method is called when the ScribeImpl splits a SubscribeMessage into multiple parts. |
ScribeContent |
ScribePolicy.DefaultScribePolicy.divideContent(java.util.List<Topic> theTopics,
ScribeContent content)
|
void |
ScribeImpl.publish(Topic topic,
ScribeContent content)
Publishes the given message to the topic. |
protected void |
ScribeImpl.recvAnycastFail(Topic topic,
NodeHandle failedAtNode,
ScribeContent content)
|
void |
ScribePolicy.recvAnycastFail(Topic topic,
NodeHandle failedAtNode,
ScribeContent content)
This notifies us when we receive a failure for a anycast |
void |
ScribePolicy.DefaultScribePolicy.recvAnycastFail(Topic topic,
NodeHandle failedAtNode,
ScribeContent content)
|
void |
ScribeImpl.subscribe(java.util.Collection<Topic> theTopics,
ScribeClient client,
ScribeContent content,
NodeHandle hint)
|
void |
ScribeImpl.subscribe(java.util.Collection<Topic> theTopics,
ScribeMultiClient client,
ScribeContent content,
NodeHandle hint)
|
void |
ScribeImpl.subscribe(Topic topic,
ScribeClient client,
ScribeContent content)
|
void |
ScribeImpl.subscribe(Topic topic,
ScribeClient client,
ScribeContent content,
NodeHandle hint)
|
void |
ScribeImpl.subscribe(Topic topic,
ScribeMultiClient client,
ScribeContent content,
NodeHandle hint)
|
protected RawScribeContent |
ScribeImpl.toRawScribeContent(ScribeContent content)
|
Uses of ScribeContent in rice.p2p.scribe.javaserialized |
---|
Methods in rice.p2p.scribe.javaserialized that return ScribeContent | |
---|---|
ScribeContent |
JavaScribeContentDeserializer.deserializeScribeContent(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
Methods in rice.p2p.scribe.javaserialized with parameters of type ScribeContent | |
---|---|
void |
JavaScribe.anycast(Topic topic,
ScribeContent content)
Anycasts the given content to a member of the given topic |
void |
JavaScribe.anycast(Topic topic,
ScribeContent content,
NodeHandle hint)
Anycasts the given content to a member of the given topic The hint helps us to implement centralized algorithms where the hint is the cachedRoot for the topic. |
void |
JavaScribe.publish(Topic topic,
ScribeContent content)
Publishes the given message to the topic. |
void |
JavaScribe.subscribe(java.util.Collection<Topic> topics,
ScribeClient client,
ScribeContent content,
NodeHandle hint)
Deprecated. use the version with the MultiClient |
void |
JavaScribe.subscribe(java.util.Collection<Topic> topics,
ScribeMultiClient client,
ScribeContent content,
NodeHandle hint)
|
void |
JavaScribe.subscribe(Topic topic,
ScribeClient client,
ScribeContent content)
Deprecated. use subscribe(Topic, ScribeMultiClient, ScribeContent, NodeHandle) |
void |
JavaScribe.subscribe(Topic topic,
ScribeClient client,
ScribeContent content,
NodeHandle hint)
Deprecated. use the version with the MultiClient |
void |
JavaScribe.subscribe(Topic topic,
ScribeMultiClient client,
ScribeContent content,
NodeHandle hint)
|
Uses of ScribeContent in rice.p2p.scribe.messaging |
---|
Methods in rice.p2p.scribe.messaging that return ScribeContent | |
---|---|
ScribeContent |
AnycastFailureMessage.getContent()
|
ScribeContent |
AnycastMessage.getContent()
Returns the content |
ScribeContent |
PublishMessage.getContent()
Returns the content |
ScribeContent |
PublishRequestMessage.getContent()
Returns the content |
Methods in rice.p2p.scribe.messaging with parameters of type ScribeContent | |
---|---|
void |
AnycastMessage.setContent(ScribeContent content)
|
void |
PublishMessage.setContent(ScribeContent content)
|
Constructors in rice.p2p.scribe.messaging with parameters of type ScribeContent | |
---|---|
AnycastFailureMessage(NodeHandle source,
Topic topic,
ScribeContent content)
|
|
AnycastMessage(NodeHandle source,
Topic topic,
ScribeContent content)
Constructor which takes a unique integer Id |
|
PublishMessage(NodeHandle source,
Topic topic,
ScribeContent content)
Constructor which takes a unique integer Id |
|
PublishRequestMessage(NodeHandle source,
Topic topic,
ScribeContent content)
Constructor which takes a unique integer Id |
Uses of ScribeContent in rice.p2p.scribe.rawserialization |
---|
Subinterfaces of ScribeContent in rice.p2p.scribe.rawserialization | |
---|---|
interface |
RawScribeContent
|
Classes in rice.p2p.scribe.rawserialization that implement ScribeContent | |
---|---|
class |
JavaSerializedScribeContent
|
Fields in rice.p2p.scribe.rawserialization declared as ScribeContent | |
---|---|
ScribeContent |
JavaSerializedScribeContent.content
|
Methods in rice.p2p.scribe.rawserialization that return ScribeContent | |
---|---|
ScribeContent |
ScribeContentDeserializer.deserializeScribeContent(InputBuffer buf,
Endpoint endpoint,
short contentType)
|
ScribeContent |
JavaSerializedScribeContent.getContent()
|
Constructors in rice.p2p.scribe.rawserialization with parameters of type ScribeContent | |
---|---|
JavaSerializedScribeContent(ScribeContent content)
|
Uses of ScribeContent in rice.p2p.scribe.testing |
---|
Classes in rice.p2p.scribe.testing that implement ScribeContent | |
---|---|
protected static class |
RawScribeRegrTest.RawTestScribeContent
Utility class for past content objects |
protected static class |
ScribeRegrTest.TestScribeContent
Utility class for past content objects |
Methods in rice.p2p.scribe.testing that return types with arguments of type ScribeContent | |
---|---|
java.util.List<ScribeContent> |
ScribeRegrTest.TestScribeClient.getAnycastMessages()
|
java.util.List<ScribeContent> |
ScribeRegrTest.TestScribeClient.getPublishMessages()
|
Methods in rice.p2p.scribe.testing with parameters of type ScribeContent | |
---|---|
boolean |
ScribeRegrTest.TestScribeClient.anycast(Topic topic,
ScribeContent content)
DESCRIBE THE METHOD |
void |
ScribeRegrTest.TestScribeClient.deliver(Topic topic,
ScribeContent content)
DESCRIBE THE METHOD |
Uses of ScribeContent in rice.p2p.splitstream |
---|
Classes in rice.p2p.splitstream that implement ScribeContent | |
---|---|
class |
SplitStreamContent
This represents data sent through scribe for splitstream |
class |
SplitStreamSubscribeContent
This represents data sent through scribe for splitstream during a subscribe |
Methods in rice.p2p.splitstream with parameters of type ScribeContent | |
---|---|
boolean |
Stripe.anycast(Topic topic,
ScribeContent content)
This method is invoked when an anycast is received for a topic which this client is interested in. |
void |
Stripe.deliver(Topic topic,
ScribeContent content)
This method is invoked when a message is delivered for a topic this client is interested in. |
void |
SplitStreamScribePolicy.recvAnycastFail(Topic topic,
NodeHandle failedAtNode,
ScribeContent content)
|
Uses of ScribeContent in rice.pastry.testing |
---|
Classes in rice.pastry.testing that implement ScribeContent | |
---|---|
protected static class |
RoutingTableTest.TestScribeContent
Utility class for past content objects |
Uses of ScribeContent in rice.tutorial.scribe |
---|
Methods in rice.tutorial.scribe with parameters of type ScribeContent | |
---|---|
boolean |
MyScribeClient.anycast(Topic topic,
ScribeContent content)
Called when we receive an anycast. |
void |
MyScribeClient.deliver(Topic topic,
ScribeContent content)
Called whenever we receive a published message. |
|
Rice Pastry API | |||||||||
PREV NEXT | FRAMES NO FRAMES |