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

---

org.activemq.broker.impl
Class AdvisorySupport  

java.lang.Object
  org.activemq.broker.impl.AdvisorySupport

---

class AdvisorySupport

extends java.lang.Object

Manages advisory subscriptions and messages

Version:

$Revision: 1.1.1.1 $

---

Field Summary
private  java.util.Set	advisoryConsumers
private  DefaultBroker	broker
private  java.util.Set	connections
private  java.util.Set	consumers
private  org.activemq.util.IdGenerator	idGen
private static org.apache.commons.logging.Log	log
private  java.util.Set	producers
private  java.util.Map	tempDestinations

 

Constructor Summary
(package private)	AdvisorySupport(DefaultBroker broker)

 

Method Summary
(package private)  void	addAdvisory(org.activemq.broker.BrokerClient sender, org.activemq.message.ConsumerInfo advisory)           Add an advisory Consumer
(package private)  void	addConnection(org.activemq.broker.BrokerClient sender, org.activemq.message.ConnectionInfo info)           Add a Connection
private  void	addConsumer(org.activemq.broker.BrokerClient sender, org.activemq.message.ConsumerInfo info)           Add a Consumer
(package private)  void	addProducer(org.activemq.broker.BrokerClient sender, org.activemq.message.ProducerInfo info)           Add a Producer
private  void	dispatchToBroker(org.activemq.broker.BrokerClient sender, org.activemq.message.ActiveMQMessage message)
private  void	dispatchToTarget(org.activemq.broker.BrokerClient target, org.activemq.message.ActiveMQMessage message)
private  org.activemq.message.ActiveMQMessage	generateAdvisory(org.activemq.message.ConsumerInfo advisory, org.activemq.message.ConnectionInfo info)
private  org.activemq.message.ActiveMQMessage	generateAdvisory(org.activemq.message.ConsumerInfo advisory, org.activemq.message.ConsumerInfo info)
private  org.activemq.message.ActiveMQMessage	generateAdvisory(org.activemq.message.ConsumerInfo advisory, org.activemq.message.ProducerInfo info)
private  org.activemq.message.ActiveMQMessage	generateAdvisory(org.activemq.message.ConsumerInfo advisory, org.activemq.advisories.TempDestinationAdvisoryEvent event)           Generate a TempDestinationAdvisoryEvent if the advisory is a match
private  org.activemq.message.ActiveMQMessage	generateAdvisoryMessage(org.activemq.message.ConsumerInfo advisoryTarget, org.activemq.message.Packet payload, org.activemq.message.ActiveMQDestination destination)           Generate an advisory message
private  org.activemq.message.ActiveMQMessage	generateAdvisoryMessage(org.activemq.message.Packet payload, org.activemq.message.ActiveMQDestination destination)           Generate an advisory message
(package private)  boolean	matchConnection(org.activemq.message.ConsumerInfo advisory, org.activemq.message.ConnectionInfo info)
(package private)  boolean	matchConsumer(org.activemq.message.ConsumerInfo advisory, org.activemq.message.ConsumerInfo info)
private  boolean	matchGeneralAdvisory(org.activemq.message.ConsumerInfo advisory, org.activemq.message.ActiveMQDestination destination)           A consumer could listen for all advisories
(package private)  boolean	matchProducer(org.activemq.message.ConsumerInfo advisory, org.activemq.message.ProducerInfo info)
(package private)  boolean	matchTempDestinationAdvisory(org.activemq.message.ConsumerInfo advisory, org.activemq.message.ActiveMQDestination destination)
(package private)  void	processTempDestinationAdvisory(org.activemq.broker.BrokerClient sender, org.activemq.message.ActiveMQMessage message)
private  void	processTempDestinationAdvisory(org.activemq.advisories.TempDestinationAdvisoryEvent event)
(package private)  void	removeAdvisory(org.activemq.broker.BrokerClient sender, org.activemq.message.ConsumerInfo info)           remove an advisory Consumer
private  void	removeAllTempDestinations(org.activemq.broker.BrokerClient sender, java.lang.String clientId)
(package private)  void	removeConnection(org.activemq.broker.BrokerClient sender, org.activemq.message.ConnectionInfo info)           Remove a Connection
private  void	removeConsumer(org.activemq.broker.BrokerClient sender, org.activemq.message.ConsumerInfo info)           Remove a Consumer
(package private)  void	removeProducer(org.activemq.broker.BrokerClient sender, org.activemq.message.ProducerInfo info)           Remove a Producer

 

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

---

advisoryConsumers

private java.util.Set advisoryConsumers

---

consumers

private java.util.Set consumers

---

producers

private java.util.Set producers

---

connections

private java.util.Set connections

---

idGen

private org.activemq.util.IdGenerator idGen

---

tempDestinations

private java.util.Map tempDestinations

---

broker

private DefaultBroker broker

Constructor Detail

AdvisorySupport

AdvisorySupport(DefaultBroker broker)

Method Detail

addAdvisory

void addAdvisory(org.activemq.broker.BrokerClient sender,
                 org.activemq.message.ConsumerInfo advisory)

Add an advisory Consumer

---

removeAdvisory

void removeAdvisory(org.activemq.broker.BrokerClient sender,
                    org.activemq.message.ConsumerInfo info)

remove an advisory Consumer

---

addConsumer

private void addConsumer(org.activemq.broker.BrokerClient sender,
                         org.activemq.message.ConsumerInfo info)

Add a Consumer

---

removeConsumer

private void removeConsumer(org.activemq.broker.BrokerClient sender,
                            org.activemq.message.ConsumerInfo info)

Remove a Consumer

---

addProducer

void addProducer(org.activemq.broker.BrokerClient sender,
                 org.activemq.message.ProducerInfo info)

Add a Producer

---

removeProducer

void removeProducer(org.activemq.broker.BrokerClient sender,
                    org.activemq.message.ProducerInfo info)

Remove a Producer

---

addConnection

void addConnection(org.activemq.broker.BrokerClient sender,
                   org.activemq.message.ConnectionInfo info)

Add a Connection

---

removeConnection

void removeConnection(org.activemq.broker.BrokerClient sender,
                      org.activemq.message.ConnectionInfo info)

Remove a Connection

---

processTempDestinationAdvisory

void processTempDestinationAdvisory(org.activemq.broker.BrokerClient sender,
                                    org.activemq.message.ActiveMQMessage message)
                              throws javax.jms.JMSException

---

generateAdvisory

private org.activemq.message.ActiveMQMessage generateAdvisory(org.activemq.message.ConsumerInfo advisory,
                                                              org.activemq.message.ConsumerInfo info)

---

generateAdvisory

private org.activemq.message.ActiveMQMessage generateAdvisory(org.activemq.message.ConsumerInfo advisory,
                                                              org.activemq.message.ProducerInfo info)

---

generateAdvisory

private org.activemq.message.ActiveMQMessage generateAdvisory(org.activemq.message.ConsumerInfo advisory,
                                                              org.activemq.message.ConnectionInfo info)

---

generateAdvisory

private org.activemq.message.ActiveMQMessage generateAdvisory(org.activemq.message.ConsumerInfo advisory,
                                                              org.activemq.advisories.TempDestinationAdvisoryEvent event)

Generate a TempDestinationAdvisoryEvent if the advisory is a match

---

matchConsumer

boolean matchConsumer(org.activemq.message.ConsumerInfo advisory,
                      org.activemq.message.ConsumerInfo info)

---

matchProducer

boolean matchProducer(org.activemq.message.ConsumerInfo advisory,
                      org.activemq.message.ProducerInfo info)

---

matchConnection

boolean matchConnection(org.activemq.message.ConsumerInfo advisory,
                        org.activemq.message.ConnectionInfo info)

---

matchGeneralAdvisory

private boolean matchGeneralAdvisory(org.activemq.message.ConsumerInfo advisory,
                                     org.activemq.message.ActiveMQDestination destination)

A consumer could listen for all advisories

---

matchTempDestinationAdvisory

boolean matchTempDestinationAdvisory(org.activemq.message.ConsumerInfo advisory,
                                     org.activemq.message.ActiveMQDestination destination)

---

processTempDestinationAdvisory

private void processTempDestinationAdvisory(org.activemq.advisories.TempDestinationAdvisoryEvent event)

---

removeAllTempDestinations

private void removeAllTempDestinations(org.activemq.broker.BrokerClient sender,
                                       java.lang.String clientId)

---

generateAdvisoryMessage

private org.activemq.message.ActiveMQMessage generateAdvisoryMessage(org.activemq.message.Packet payload,
                                                                     org.activemq.message.ActiveMQDestination destination)

Generate an advisory message

---

generateAdvisoryMessage

private org.activemq.message.ActiveMQMessage generateAdvisoryMessage(org.activemq.message.ConsumerInfo advisoryTarget,
                                                                     org.activemq.message.Packet payload,
                                                                     org.activemq.message.ActiveMQDestination destination)

Generate an advisory message

---

dispatchToTarget

private void dispatchToTarget(org.activemq.broker.BrokerClient target,
                              org.activemq.message.ActiveMQMessage message)

---

dispatchToBroker

private void dispatchToBroker(org.activemq.broker.BrokerClient sender,
                              org.activemq.message.ActiveMQMessage message)

---

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

---