public class DestinationSource extends Object implements MessageListener
Constructor and Description |
---|
DestinationSource(Connection connection) |
Modifier and Type | Method and Description |
---|---|
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() |
public DestinationSource(Connection connection) throws JMSException
JMSException
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)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.