Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.advisories
Class TempDestinationAdvisor  view TempDestinationAdvisor download TempDestinationAdvisor.java

java.lang.Object
  extended byorg.activemq.advisories.TempDestinationAdvisor
All Implemented Interfaces:
javax.jms.MessageListener

public class TempDestinationAdvisor
extends java.lang.Object
implements javax.jms.MessageListener

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:
onMessage in interface javax.jms.MessageListener

fireEvent

private void fireEvent(TempDestinationAdvisoryEvent event)