|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectdermi.session.NotificationParser
This class encapsulates a notification parser which is notified about events, and dispatches them to the different clients subscribed
Constructor Summary | |
---|---|
NotificationParser(ConnectionListener connsubs)
Constructor |
|
NotificationParser(RemoteEventListener subs)
Constructor |
|
NotificationParser(RemoteInterceptorListener filtsubs)
Constructor |
Method Summary | |
---|---|
boolean |
anycast(rice.p2p.scribe.Topic topic,
rice.p2p.scribe.ScribeContent cnt)
Invoked when an anycast event is received |
void |
childAdded(rice.p2p.scribe.Topic topic,
rice.p2p.commonapi.NodeHandle nodeHandle)
Activated when a child is added to this node in the multicast group |
void |
childRemoved(rice.p2p.scribe.Topic topic,
rice.p2p.commonapi.NodeHandle nodeHandle)
Activated when a child is removed from this node in the multicast group |
void |
close()
Closes bus connection |
void |
deliver(rice.p2p.scribe.Topic topic,
rice.p2p.scribe.ScribeContent scribeContent)
Invoked when an event is received |
rice.p2p.scribe.ScribeContent |
interceptAnycast(rice.p2p.scribe.Topic topic,
rice.p2p.scribe.ScribeContent cnt)
Invoked when an anycast event is received |
void |
receiveInterceptorMessage(java.util.Hashtable msg,
java.util.ArrayList interceptors)
Invoked when an interception message is received |
void |
setConnection(DermiConnection conn)
Sets this parser's connection |
void |
subscribeFailed(rice.p2p.scribe.Topic topic)
Activated when a subscription failure is detected |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public NotificationParser(RemoteEventListener subs)
subs
- RemoteEventListener Application to be notifiedpublic NotificationParser(RemoteInterceptorListener filtsubs)
filtsubs
- RemoteInterceptorListener Interceptor application to be notifiedpublic NotificationParser(ConnectionListener connsubs)
connsubs
- ConnectionListener Connection listener to be notifiedMethod Detail |
---|
public void setConnection(DermiConnection conn)
setConnection
in interface DermiApplicationListener
conn
- DermiConnectionpublic boolean anycast(rice.p2p.scribe.Topic topic, rice.p2p.scribe.ScribeContent cnt)
anycast
in interface rice.p2p.scribe.ScribeClient
topic
- Topic Group's identifiercnt
- ScribeContent Anycast's content
public rice.p2p.scribe.ScribeContent interceptAnycast(rice.p2p.scribe.Topic topic, rice.p2p.scribe.ScribeContent cnt)
interceptAnycast
in interface DermiApplicationListener
topic
- Topic Group's identifiercnt
- ScribeContent Original anycast message
public void close()
public void receiveInterceptorMessage(java.util.Hashtable msg, java.util.ArrayList interceptors)
receiveInterceptorMessage
in interface DermiApplicationListener
msg
- Hashtable The message datainterceptors
- ArrayList Remaining interceptors listpublic void deliver(rice.p2p.scribe.Topic topic, rice.p2p.scribe.ScribeContent scribeContent)
deliver
in interface rice.p2p.scribe.ScribeClient
topic
- Topic Group's identifierscribeContent
- ScribeContent Message contentpublic void childAdded(rice.p2p.scribe.Topic topic, rice.p2p.commonapi.NodeHandle nodeHandle)
childAdded
in interface rice.p2p.scribe.ScribeClient
topic
- Topic Group's identifiernodeHandle
- NodeHandle Child's node handlepublic void childRemoved(rice.p2p.scribe.Topic topic, rice.p2p.commonapi.NodeHandle nodeHandle)
childRemoved
in interface rice.p2p.scribe.ScribeClient
topic
- Topic Group's identifiernodeHandle
- NodeHandle Child's node handlepublic void subscribeFailed(rice.p2p.scribe.Topic topic)
subscribeFailed
in interface rice.p2p.scribe.ScribeClient
topic
- Topic Group's identifier
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |