osmq.util
Class TopicsListeners
java.lang.Object
osmq.util.TopicsListeners
- All Implemented Interfaces:
- MessageListener
- public class TopicsListeners
- extends java.lang.Object
- implements MessageListener
Supports differentiating MessageListener instance by topic.
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
TopicsListeners
public TopicsListeners()
setDefaultListener
public void setDefaultListener(MessageListener listener)
getDefaultListener
public MessageListener getDefaultListener()
add
public void add(java.lang.String topic,
MessageListener listener)
hasTopic
public boolean hasTopic(java.lang.String topic)
delete
public void delete(java.lang.String topic)
getCount
public int getCount()
onMessage
public void onMessage(Message cm)
- Specified by:
onMessage
in interface MessageListener