|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.advisory.DestinationSource
public class DestinationSource
A helper class which keeps track of the Destinations available in a broker and allows you to listen to them being created or deleted.
Constructor Summary | |
---|---|
DestinationSource(Connection connection)
|
Method Summary | |
---|---|
protected void |
fireDestinationEvent(DestinationEvent event)
|
DestinationListener |
getListener()
|
Set<ActiveMQQueue> |
getQueues()
Returns the current queues available on the broker |
Set<ActiveMQTempQueue> |
getTemporaryQueues()
Returns the current temporary topics available on the broker |
Set<ActiveMQTempTopic> |
getTemporaryTopics()
Returns the current temporary queues available on the broker |
Set<ActiveMQTopic> |
getTopics()
Returns the current topics on the broker |
void |
onMessage(Message message)
|
void |
setDestinationListener(DestinationListener listener)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DestinationSource(Connection connection) throws JMSException
JMSException
Method Detail |
---|
public DestinationListener getListener()
public void setDestinationListener(DestinationListener listener)
public Set<ActiveMQQueue> getQueues()
public Set<ActiveMQTopic> getTopics()
public Set<ActiveMQTempQueue> getTemporaryQueues()
public Set<ActiveMQTempTopic> getTemporaryTopics()
public void start() throws JMSException
JMSException
public void stop() throws JMSException
JMSException
public void onMessage(Message message)
onMessage
in interface MessageListener
protected void fireDestinationEvent(DestinationEvent event)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |