public class StatisticsBroker extends BrokerFilter
Modifier and Type | Field and Description |
---|---|
protected ProducerId |
advisoryProducerId |
protected BrokerViewMBean |
brokerView |
next
Constructor and Description |
---|
StatisticsBroker(Broker next)
Constructor
|
Modifier and Type | Method and Description |
---|---|
protected ActiveMQMapMessage |
prepareSubscriptionMessage(SubscriptionViewMBean subscriber) |
void |
send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode
|
protected void |
sendStats(ConnectionContext context,
ActiveMQMapMessage msg,
ActiveMQDestination replyTo) |
protected void |
sendSubStats(ConnectionContext context,
javax.management.ObjectName[] subscribers,
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
protected BrokerViewMBean brokerView
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 sendSubStats(ConnectionContext context, javax.management.ObjectName[] subscribers, ActiveMQDestination replyTo) throws java.lang.Exception
java.lang.Exception
protected ActiveMQMapMessage prepareSubscriptionMessage(SubscriptionViewMBean subscriber) throws javax.jms.JMSException
javax.jms.JMSException
protected void sendStats(ConnectionContext context, ActiveMQMapMessage msg, ActiveMQDestination replyTo) throws java.lang.Exception
java.lang.Exception
Copyright © 2005-2017. All Rights Reserved.