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,
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, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getNext, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, virtualDestinationAdded, virtualDestinationRemoved
protected final ProducerId advisoryProducerId
protected BrokerViewMBean brokerView
public StatisticsBroker(Broker next)
next
- public void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.Exception
- TODOBrokerFilter.send(org.apache.activemq.broker.ProducerBrokerExchange,
org.apache.activemq.command.Message)
public void start() throws Exception
start
in interface Service
start
in class BrokerFilter
Exception
public void stop() throws Exception
stop
in interface Service
stop
in class BrokerFilter
Exception
protected void sendSubStats(ConnectionContext context, ObjectName[] subscribers, ActiveMQDestination replyTo) throws Exception
Exception
protected ActiveMQMapMessage prepareSubscriptionMessage(SubscriptionViewMBean subscriber) throws javax.jms.JMSException
javax.jms.JMSException
protected void sendStats(ConnectionContext context, ActiveMQMapMessage msg, ActiveMQDestination replyTo) throws Exception
Exception
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.