|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.BrokerFilter
org.apache.activemq.advisory.AdvisoryBroker
public class AdvisoryBroker
This broker filter handles tracking the state of the broker for purposes of publishing advisory messages to advisory consumers.
Field Summary | |
---|---|
protected ProducerId |
advisoryProducerId
|
protected edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap |
connections
|
protected edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap |
consumers
|
protected edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap |
destinations
|
protected edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap |
producers
|
Fields inherited from class org.apache.activemq.broker.BrokerFilter |
---|
next |
Constructor Summary | |
---|---|
AdvisoryBroker(Broker next)
|
Method Summary | |
---|---|
void |
addConnection(ConnectionContext context,
ConnectionInfo info)
A client is establishing a connection with the broker. |
Subscription |
addConsumer(ConnectionContext context,
ConsumerInfo info)
Adds a consumer. |
Destination |
addDestination(ConnectionContext context,
ActiveMQDestination destination)
Used to create a destination. |
void |
addDestinationInfo(ConnectionContext context,
DestinationInfo info)
Add and process a DestinationInfo object |
void |
addProducer(ConnectionContext context,
ProducerInfo info)
Adds a producer. |
protected void |
fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command)
|
protected void |
fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId)
|
protected void |
fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId,
ActiveMQMessage advisoryMessage)
|
protected void |
fireConsumerAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command)
|
protected void |
fireConsumerAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId)
|
protected void |
fireProducerAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command)
|
protected void |
fireProducerAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId)
|
void |
removeConnection(ConnectionContext context,
ConnectionInfo info,
java.lang.Throwable error)
A client is disconnecting from the broker. |
void |
removeConsumer(ConnectionContext context,
ConsumerInfo info)
Removes a consumer. |
void |
removeDestination(ConnectionContext context,
ActiveMQDestination destination,
long timeout)
Used to destroy a destination. |
void |
removeDestinationInfo(ConnectionContext context,
DestinationInfo destInfo)
Remove and process a DestinationInfo object |
void |
removeProducer(ConnectionContext context,
ProducerInfo info)
Removes a producer. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap connections
protected final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap consumers
protected final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap producers
protected final edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap destinations
protected final ProducerId advisoryProducerId
Constructor Detail |
---|
public AdvisoryBroker(Broker next)
Method Detail |
---|
public void addConnection(ConnectionContext context, ConnectionInfo info) throws java.lang.Exception
Broker
addConnection
in interface Broker
addConnection
in class BrokerFilter
java.lang.Exception
- TODOpublic Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Broker
addProducer
in interface Broker
addProducer
in class BrokerFilter
context
- the enviorment the operation is being executed under.
java.lang.Exception
- TODOpublic Destination addDestination(ConnectionContext context, ActiveMQDestination destination) throws java.lang.Exception
Region
addDestination
in interface Region
addDestination
in class BrokerFilter
destination
- the destination to create.
java.lang.Exception
- TODOpublic void addDestinationInfo(ConnectionContext context, DestinationInfo info) throws java.lang.Exception
Broker
addDestinationInfo
in interface Broker
addDestinationInfo
in class BrokerFilter
java.lang.Exception
public void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws java.lang.Exception
Region
removeDestination
in interface Region
removeDestination
in class BrokerFilter
context
- the environment the operation is being executed under.destination
- what is being removed from the broker.timeout
- the max amount of time to wait for the destination to quiesce
java.lang.Exception
- TODOpublic void removeDestinationInfo(ConnectionContext context, DestinationInfo destInfo) throws java.lang.Exception
Broker
removeDestinationInfo
in interface Broker
removeDestinationInfo
in class BrokerFilter
java.lang.Exception
public void removeConnection(ConnectionContext context, ConnectionInfo info, java.lang.Throwable error) throws java.lang.Exception
Broker
removeConnection
in interface Broker
removeConnection
in class BrokerFilter
context
- the environment the operation is being executed under.error
- null if the client requested the disconnect or the error that caused the client to disconnect.
java.lang.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws java.lang.Exception
Region
removeConsumer
in interface Region
removeConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.
java.lang.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws java.lang.Exception
Broker
removeProducer
in interface Broker
removeProducer
in class BrokerFilter
context
- the enviorment the operation is being executed under.
java.lang.Exception
- TODOprotected void fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command) throws java.lang.Exception
java.lang.Exception
protected void fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId) throws java.lang.Exception
java.lang.Exception
protected void fireConsumerAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command) throws java.lang.Exception
java.lang.Exception
protected void fireConsumerAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId) throws java.lang.Exception
java.lang.Exception
protected void fireProducerAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command) throws java.lang.Exception
java.lang.Exception
protected void fireProducerAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId) throws java.lang.Exception
java.lang.Exception
protected void fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId, ActiveMQMessage advisoryMessage) throws java.lang.Exception
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |