org.apache.activemq.advisory
Class DestinationSource

java.lang.Object
  extended by org.apache.activemq.advisory.DestinationSource
All Implemented Interfaces:
MessageListener

public class DestinationSource
extends Object
implements MessageListener

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

DestinationSource

public DestinationSource(Connection connection)
                  throws JMSException
Throws:
JMSException
Method Detail

getListener

public DestinationListener getListener()

setDestinationListener

public void setDestinationListener(DestinationListener listener)

getQueues

public Set<ActiveMQQueue> getQueues()
Returns the current queues available on the broker


getTopics

public Set<ActiveMQTopic> getTopics()
Returns the current topics on the broker


getTemporaryQueues

public Set<ActiveMQTempQueue> getTemporaryQueues()
Returns the current temporary topics available on the broker


getTemporaryTopics

public Set<ActiveMQTempTopic> getTemporaryTopics()
Returns the current temporary queues available on the broker


start

public void start()
           throws JMSException
Throws:
JMSException

stop

public void stop()
          throws JMSException
Throws:
JMSException

onMessage

public void onMessage(Message message)
Specified by:
onMessage in interface MessageListener

fireDestinationEvent

protected void fireDestinationEvent(DestinationEvent event)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.