|
|||||||||
| Home >> All >> org >> activemq >> [ advisories overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
org.activemq.advisories
Class TempDestinationAdvisor

java.lang.Objectorg.activemq.advisories.TempDestinationAdvisor
- All Implemented Interfaces:
- javax.jms.MessageListener
- public class TempDestinationAdvisor
- extends java.lang.Object
- implements javax.jms.MessageListener
- extends java.lang.Object
A helper class for listening for TempDestination advisories
- Version:
- $Revision: 1.1.1.1 $
| Field Summary | |
private java.util.Set |
activeDestinations
|
private javax.jms.Connection |
connection
|
private org.activemq.message.ActiveMQDestination |
destination
|
private java.util.List |
listeners
|
private static org.apache.commons.logging.Log |
log
|
private javax.jms.Session |
session
|
private SynchronizedBoolean |
started
|
private long |
startedAt
|
| Constructor Summary | |
TempDestinationAdvisor(javax.jms.Connection connection,
javax.jms.Destination destination)
Construct a TempDestinationAdvisor |
|
| Method Summary | |
void |
addListener(TempDestinationAdvisoryEventListener l)
Add a listener |
private void |
fireEvent(TempDestinationAdvisoryEvent event)
|
boolean |
isActive(javax.jms.Destination destination)
returns true if the temporary destination is active |
void |
onMessage(javax.jms.Message msg)
OnMessage() implementation |
void |
removeListener(TempDestinationAdvisoryEventListener l)
Remove a listener |
void |
start()
start listening for advisories |
void |
stop()
stop listening for advisories |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
log
private static final org.apache.commons.logging.Log log
connection
private javax.jms.Connection connection
destination
private org.activemq.message.ActiveMQDestination destination
session
private javax.jms.Session session
listeners
private java.util.List listeners
activeDestinations
private java.util.Set activeDestinations
started
private SynchronizedBoolean started
startedAt
private long startedAt
| Constructor Detail |
TempDestinationAdvisor
public TempDestinationAdvisor(javax.jms.Connection connection, javax.jms.Destination destination) throws javax.jms.JMSException
- Construct a TempDestinationAdvisor
| Method Detail |
start
public void start()
throws javax.jms.JMSException
- start listening for advisories
stop
public void stop()
throws javax.jms.JMSException
- stop listening for advisories
isActive
public boolean isActive(javax.jms.Destination destination)
- returns true if the temporary destination is active
addListener
public void addListener(TempDestinationAdvisoryEventListener l)
- Add a listener
removeListener
public void removeListener(TempDestinationAdvisoryEventListener l)
- Remove a listener
onMessage
public void onMessage(javax.jms.Message msg)
- OnMessage() implementation
- Specified by:
onMessagein interfacejavax.jms.MessageListener
fireEvent
private void fireEvent(TempDestinationAdvisoryEvent event)
|
|||||||||
| Home >> All >> org >> activemq >> [ advisories overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
JAVADOC
org.activemq.advisories.TempDestinationAdvisor