public class StatisticsBroker extends BrokerFilter
Modifier and Type | Field and Description |
---|---|
protected ProducerId |
advisoryProducerId |
next
Constructor and Description |
---|
StatisticsBroker(Broker next)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode
|
protected void |
sendStats(ConnectionContext context,
ActiveMQMapMessage msg,
ActiveMQDestination replyTo) |
void |
start() |
void |
stop() |
acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer
protected final ProducerId advisoryProducerId
public StatisticsBroker(Broker next)
next
- public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws java.lang.Exception
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.java.lang.Exception
- TODOBrokerFilter.send(org.apache.activemq.broker.ProducerBrokerExchange,
org.apache.activemq.command.Message)
public void start() throws java.lang.Exception
start
in interface Service
start
in class BrokerFilter
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
stop
in class BrokerFilter
java.lang.Exception
protected void sendStats(ConnectionContext context, ActiveMQMapMessage msg, ActiveMQDestination replyTo) throws java.lang.Exception
java.lang.Exception
Copyright © 2005-2012. All Rights Reserved.