public class TopicsScope extends java.lang.Object implements MultiPeerListener
Modifier and Type | Field and Description |
---|---|
private MultiPeer |
netPeers |
private java.util.HashMap<java.lang.String,Topic> |
topics |
Constructor and Description |
---|
TopicsScope() |
TopicsScope(MultiPeer mp) |
Modifier and Type | Method and Description |
---|---|
private void |
askForSuscription() |
MultiPeer |
getMultiPeer() |
Topic |
lookup(java.lang.String topicName) |
private void |
notifyUnSuscription(java.lang.String name) |
void |
onMessage(Message m) |
void |
onNewConnection(Destination dest) |
boolean |
unSuscribe(java.lang.String topicName) |
private MultiPeer netPeers
private java.util.HashMap<java.lang.String,Topic> topics
public TopicsScope()
public TopicsScope(MultiPeer mp)
private void askForSuscription()
public MultiPeer getMultiPeer()
public Topic lookup(java.lang.String topicName)
private void notifyUnSuscription(java.lang.String name)
public void onMessage(Message m)
onMessage
in interface MultiPeerListener
public void onNewConnection(Destination dest)
onNewConnection
in interface MultiPeerListener
public boolean unSuscribe(java.lang.String topicName)