|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectrice.p2p.scribe.ScribeImpl
dermi.core.DermiKernel
This class implements the kernel of Dermi. It extends the Scribe event service to provide all the features and services
Nested Class Summary |
---|
Nested classes inherited from class rice.p2p.scribe.ScribeImpl |
---|
rice.p2p.scribe.ScribeImpl.TopicManager |
Field Summary |
---|
Fields inherited from class rice.p2p.scribe.ScribeImpl |
---|
endpoint, handle, log, MESSAGE_TIMEOUT, policy, topics |
Constructor Summary | |
---|---|
DermiKernel(java.lang.String instance,
DermiConnection conn)
The kernel constructor |
Method Summary | |
---|---|
void |
addInterceptor(rice.p2p.scribe.ScribeClient client,
rice.p2p.scribe.Topic topic,
java.lang.String intId)
Method for adding an interceptor object to an object group |
void |
continueInterception(java.util.Hashtable evt,
java.util.ArrayList interceptors)
Method invoked by interceptor skeletons to resume the interception process |
void |
deliver(rice.p2p.commonapi.Id id,
rice.p2p.commonapi.Message message)
This method is called on the application at the destination node for the given id. |
boolean |
forward(rice.p2p.commonapi.RouteMessage message)
The Common API forward method has been changed to first pass the RouteMessage to Dermi's notification parser, so as to be able to route new messages with contents changes (useful in manycalls) |
rice.p2p.commonapi.NodeHandle |
getLocalNodeHandle()
Returns the local node handle |
void |
publishDirect(rice.p2p.scribe.Topic topic,
DermiContent content)
Publishes a direct message to the topic. |
void |
removeInterceptor(rice.p2p.scribe.Topic topic,
java.lang.String intId)
Method for removing an interceptor from an object group |
void |
update(rice.p2p.commonapi.NodeHandle handle,
boolean joined)
This method is invoked to inform the application that the given node has either joined or left the neighbor set of the local node, as the set would be returned by the neighborSet call. |
Methods inherited from class rice.p2p.scribe.ScribeImpl |
---|
addChild, anycast, getChildren, getClients, getId, getParent, getPolicy, isRoot, publish, removeChild, removeChild, sendSubscribe, setPolicy, subscribe, subscribe, unsubscribe |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DermiKernel(java.lang.String instance, DermiConnection conn)
instance
- String Instance nameconn
- DermiConnection The connection nodeMethod Detail |
---|
public void addInterceptor(rice.p2p.scribe.ScribeClient client, rice.p2p.scribe.Topic topic, java.lang.String intId)
client
- ScribeClient Interceptor applicationtopic
- Topic Group's identifierintId
- String Interceptor idpublic void removeInterceptor(rice.p2p.scribe.Topic topic, java.lang.String intId)
topic
- Topic Group's identifierintId
- String Interceptor idpublic rice.p2p.commonapi.NodeHandle getLocalNodeHandle()
public void publishDirect(rice.p2p.scribe.Topic topic, DermiContent content)
topic
- The topic to publish tocontent
- The content to publishpublic void update(rice.p2p.commonapi.NodeHandle handle, boolean joined)
update
in interface rice.p2p.commonapi.Application
update
in class rice.p2p.scribe.ScribeImpl
handle
- The handle that has joined/leftjoined
- Whether the node has joined or leftpublic boolean forward(rice.p2p.commonapi.RouteMessage message)
forward
in interface rice.p2p.commonapi.Application
forward
in class rice.p2p.scribe.ScribeImpl
message
- RouteMessage Received message
public void deliver(rice.p2p.commonapi.Id id, rice.p2p.commonapi.Message message)
deliver
in interface rice.p2p.commonapi.Application
deliver
in class rice.p2p.scribe.ScribeImpl
id
- The destination id of the messagemessage
- The message being sentpublic void continueInterception(java.util.Hashtable evt, java.util.ArrayList interceptors)
evt
- Hashtable Event datainterceptors
- ArrayList Remaining interceptors to be traversed
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |