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 Exception
BrokerPlugin
installPlugin
in interface BrokerPlugin
Exception
public void start() throws Exception
start
in interface Service
start
in class MutableBrokerFilter
Exception
Copyright © 2005–2015. All rights reserved.