Overview  Package   Class  Use  Deprecated  Index
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 ConsumerAdvisor  

java.lang.Object
  org.activemq.advisories.ConsumerAdvisor

All Implemented Interfaces:

javax.jms.MessageListener

---

public class ConsumerAdvisor

extends java.lang.Object

implements javax.jms.MessageListener

A helper class for listening for MessageConsumer advisories

Version:

$Revision: 1.1.1.1 $

---

Field Summary
private  java.util.Map	activeSubscribers
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

 

Constructor Summary

ConsumerAdvisor(javax.jms.Connection connection, javax.jms.Destination destination)           Construct a ConsumerAdvisor

 

Method Summary
java.util.Set	activeConsumers(javax.jms.Destination destination)           return a set of active ConsumerInfo's for a particular destination
void	addListener(ConsumerAdvisoryEventListener l)           Add a listener
private  void	fireEvent(ConsumerAdvisoryEvent event)
boolean	isActive(javax.jms.Destination destination)           returns true if there is an active subscriber for the destination
void	onMessage(javax.jms.Message msg)           OnMessage() implementation
void	removeListener(ConsumerAdvisoryEventListener l)           Remove a listener
void	start()           start listening for advisories
void	stop()           stop listening for advisories
private  void	updateActiveConsumers(org.activemq.message.ConsumerInfo info)

 

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

---

started

private SynchronizedBoolean started

---

activeSubscribers

private java.util.Map activeSubscribers

Constructor Detail

ConsumerAdvisor

public ConsumerAdvisor(javax.jms.Connection connection,
                       javax.jms.Destination destination)
                throws javax.jms.JMSException

Construct a ConsumerAdvisor

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

---

addListener

public void addListener(ConsumerAdvisoryEventListener l)

Add a listener

---

removeListener

public void removeListener(ConsumerAdvisoryEventListener l)

Remove a listener

---

isActive

public boolean isActive(javax.jms.Destination destination)

returns true if there is an active subscriber for the destination

---

activeConsumers

public java.util.Set activeConsumers(javax.jms.Destination destination)

return a set of active ConsumerInfo's for a particular destination

---

onMessage

public void onMessage(javax.jms.Message msg)

OnMessage() implementation

Specified by:

onMessage in interface javax.jms.MessageListener

---

fireEvent

private void fireEvent(ConsumerAdvisoryEvent event)

---

updateActiveConsumers

private void updateActiveConsumers(org.activemq.message.ConsumerInfo info)

---

Overview  Package   Class  Use  Deprecated  Index
Home >> All >> org >> activemq >> [ advisories overview ]	PREV CLASS  NEXT CLASS
SUMMARY:  JAVADOC |  SOURCE |  DOWNLOAD | NESTED | FIELD | CONSTR | METHOD	DETAIL: FIELD | CONSTR | METHOD

---