public class AdvisoryBroker extends BrokerFilter
Modifier and Type | Field and Description |
---|---|
protected ProducerId |
advisoryProducerId |
protected ConcurrentHashMap<ConnectionId,ConnectionInfo> |
connections |
protected ConcurrentHashMap<ConsumerId,ConsumerInfo> |
consumers |
protected ConcurrentHashMap<ActiveMQDestination,DestinationInfo> |
destinations |
protected ConcurrentHashMap<BrokerInfo,ActiveMQMessage> |
networkBridges |
protected ConcurrentHashMap<ProducerId,ProducerInfo> |
producers |
next
Constructor and Description |
---|
AdvisoryBroker(Broker next) |
Modifier and Type | Method and Description |
---|---|
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,
boolean create)
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.
|
void |
fastProducer(ConnectionContext context,
ProducerInfo producerInfo)
Called to notify a producer is too fast
|
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,
ActiveMQDestination consumerDestination,
ActiveMQTopic topic,
Command command) |
protected void |
fireConsumerAdvisory(ConnectionContext context,
ActiveMQDestination consumerDestination,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId) |
protected void |
fireProducerAdvisory(ConnectionContext context,
ActiveMQDestination producerDestination,
ActiveMQTopic topic,
Command command) |
protected void |
fireProducerAdvisory(ConnectionContext context,
ActiveMQDestination producerDestination,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId) |
Map<ConnectionId,ConnectionInfo> |
getAdvisoryConnections() |
Map<ConsumerId,ConsumerInfo> |
getAdvisoryConsumers() |
Map<ActiveMQDestination,DestinationInfo> |
getAdvisoryDestinations() |
Map<ProducerId,ProducerInfo> |
getAdvisoryProducers() |
void |
isFull(ConnectionContext context,
Destination destination,
Usage usage)
Called when a Usage reaches a limit
|
void |
messageConsumed(ConnectionContext context,
MessageReference messageReference)
called when message is consumed
|
void |
messageDelivered(ConnectionContext context,
MessageReference messageReference)
Called when message is delivered to the broker
|
void |
messageDiscarded(ConnectionContext context,
Subscription sub,
MessageReference messageReference)
Called when a message is discarded - e.g.
|
void |
messageExpired(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
A Message has Expired
|
void |
networkBridgeStarted(BrokerInfo brokerInfo,
boolean createdByDuplex,
String remoteIp) |
void |
networkBridgeStopped(BrokerInfo brokerInfo) |
void |
nowMasterBroker()
called when the broker becomes the master in a master/slave
configuration
|
void |
removeConnection(ConnectionContext context,
ConnectionInfo info,
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.
|
void |
sendToDeadLetterQueue(ConnectionContext context,
MessageReference messageReference,
Subscription subscription)
A message needs to go the a DLQ
|
void |
slowConsumer(ConnectionContext context,
Destination destination,
Subscription subs)
Called when there is a slow consumer
|
acknowledge, addBroker, addSession, beginTransaction, brokerServiceStarted, commitTransaction, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isStopped, messagePull, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, removeBroker, removeSession, removeSubscription, rollbackTransaction, send, setAdminConnectionContext, start, stop
protected final ConcurrentHashMap<ConnectionId,ConnectionInfo> connections
protected final ConcurrentHashMap<ConsumerId,ConsumerInfo> consumers
protected final ConcurrentHashMap<ProducerId,ProducerInfo> producers
protected final ConcurrentHashMap<ActiveMQDestination,DestinationInfo> destinations
protected final ConcurrentHashMap<BrokerInfo,ActiveMQMessage> networkBridges
protected final ProducerId advisoryProducerId
public AdvisoryBroker(Broker next)
public void addConnection(ConnectionContext context, ConnectionInfo info) throws Exception
Broker
addConnection
in interface Broker
addConnection
in class BrokerFilter
Exception
- TODOpublic Subscription addConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
addConsumer
in interface Region
addConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void addProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
addProducer
in interface Broker
addProducer
in interface Region
addProducer
in class BrokerFilter
context
- the enviorment the operation is being executed under.Exception
- TODOpublic Destination addDestination(ConnectionContext context, ActiveMQDestination destination, boolean create) throws Exception
Region
addDestination
in interface Region
addDestination
in class BrokerFilter
destination
- the destination to create.Exception
- TODOpublic void addDestinationInfo(ConnectionContext context, DestinationInfo info) throws Exception
Broker
addDestinationInfo
in interface Broker
addDestinationInfo
in class BrokerFilter
Exception
public void removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) throws 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 quiesceException
- TODOpublic void removeDestinationInfo(ConnectionContext context, DestinationInfo destInfo) throws Exception
Broker
removeDestinationInfo
in interface Broker
removeDestinationInfo
in class BrokerFilter
Exception
public void removeConnection(ConnectionContext context, ConnectionInfo info, Throwable error) throws 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.Exception
- TODOpublic void removeConsumer(ConnectionContext context, ConsumerInfo info) throws Exception
Region
removeConsumer
in interface Region
removeConsumer
in class BrokerFilter
context
- the environment the operation is being executed under.Exception
- TODOpublic void removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
Broker
removeProducer
in interface Broker
removeProducer
in interface Region
removeProducer
in class BrokerFilter
context
- the enviorment the operation is being executed under.Exception
- TODOpublic void messageExpired(ConnectionContext context, MessageReference messageReference, Subscription subscription)
Broker
messageExpired
in interface Broker
messageExpired
in class BrokerFilter
public void messageConsumed(ConnectionContext context, MessageReference messageReference)
Broker
messageConsumed
in interface Broker
messageConsumed
in class BrokerFilter
public void messageDelivered(ConnectionContext context, MessageReference messageReference)
Broker
messageDelivered
in interface Broker
messageDelivered
in class BrokerFilter
public void messageDiscarded(ConnectionContext context, Subscription sub, MessageReference messageReference)
Broker
messageDiscarded
in interface Broker
messageDiscarded
in class BrokerFilter
public void slowConsumer(ConnectionContext context, Destination destination, Subscription subs)
Broker
slowConsumer
in interface Broker
slowConsumer
in class BrokerFilter
public void fastProducer(ConnectionContext context, ProducerInfo producerInfo)
Broker
fastProducer
in interface Broker
fastProducer
in class BrokerFilter
public void isFull(ConnectionContext context, Destination destination, Usage usage)
Broker
isFull
in interface Broker
isFull
in class BrokerFilter
public void nowMasterBroker()
Broker
nowMasterBroker
in interface Broker
nowMasterBroker
in class BrokerFilter
public void sendToDeadLetterQueue(ConnectionContext context, MessageReference messageReference, Subscription subscription)
Broker
sendToDeadLetterQueue
in interface Broker
sendToDeadLetterQueue
in class BrokerFilter
public void networkBridgeStarted(BrokerInfo brokerInfo, boolean createdByDuplex, String remoteIp)
networkBridgeStarted
in interface Broker
networkBridgeStarted
in class BrokerFilter
public void networkBridgeStopped(BrokerInfo brokerInfo)
networkBridgeStopped
in interface Broker
networkBridgeStopped
in class BrokerFilter
protected void fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command) throws Exception
Exception
protected void fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId) throws Exception
Exception
protected void fireConsumerAdvisory(ConnectionContext context, ActiveMQDestination consumerDestination, ActiveMQTopic topic, Command command) throws Exception
Exception
protected void fireConsumerAdvisory(ConnectionContext context, ActiveMQDestination consumerDestination, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId) throws Exception
Exception
protected void fireProducerAdvisory(ConnectionContext context, ActiveMQDestination producerDestination, ActiveMQTopic topic, Command command) throws Exception
Exception
protected void fireProducerAdvisory(ConnectionContext context, ActiveMQDestination producerDestination, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId) throws Exception
Exception
protected void fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command, ConsumerId targetConsumerId, ActiveMQMessage advisoryMessage) throws Exception
Exception
public Map<ConnectionId,ConnectionInfo> getAdvisoryConnections()
public Map<ConsumerId,ConsumerInfo> getAdvisoryConsumers()
public Map<ProducerId,ProducerInfo> getAdvisoryProducers()
public Map<ActiveMQDestination,DestinationInfo> getAdvisoryDestinations()
Copyright © 2005–2016. All rights reserved.