org.apache.activemq.broker
public abstract class BrokerPluginSupport extends MutableBrokerFilter implements BrokerPlugin
next
Constructor and Description |
---|
BrokerPluginSupport() |
Modifier and Type | Method and Description |
---|---|
Broker |
installPlugin(Broker broker)
Installs the plugin into the interceptor chain of the broker, returning the new
intercepted broker to use.
|
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, getNext, 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, send, sendToDeadLetterQueue, setAdminConnectionContext, setNext, slowConsumer
public BrokerPluginSupport()
public Broker installPlugin(Broker broker) throws java.lang.Exception
BrokerPlugin
installPlugin
in interface BrokerPlugin
java.lang.Exception
public void start() throws java.lang.Exception
start
in interface Service
start
in class MutableBrokerFilter
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
stop
in class MutableBrokerFilter
java.lang.Exception
Copyright © 2005-2014. All Rights Reserved.