org.apache.activemq.broker
Class BrokerPluginSupport

java.lang.Object
  org.apache.activemq.broker.MutableBrokerFilter
      org.apache.activemq.broker.BrokerPluginSupport

All Implemented Interfaces:

Broker, BrokerPlugin, Region, Service

Direct Known Subclasses:

LoggingBrokerPlugin, TimeStampingBrokerPlugin, UDPTraceBrokerPlugin

public abstract class BrokerPluginSupport
extends MutableBrokerFilter
implements BrokerPlugin

A useful base class for implementing broker plugins.

Version:

$Revision: 426366 $

Constructor Summary

BrokerPluginSupport()

Method Summary

Broker

installPlugin(Broker broker) Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.

Methods inherited from class org.apache.activemq.broker.MutableBrokerFilter

acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, commitTransaction, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getNext, getPeerBrokerInfos, getPendingDurableSubscriberPolicy, getPreparedTransactions, getTempDataStore, isFaultTolerantConfiguration, isSlaveBroker, isStopped, messagePull, prepareTransaction, processDispatch, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, setAdminConnectionContext, setNext, setPendingDurableSubscriberPolicy, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BrokerPluginSupport

public BrokerPluginSupport()

Method Detail

installPlugin

public Broker installPlugin(Broker broker)
                     throws java.lang.Exception

Description copied from interface: BrokerPlugin

Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.

Specified by:

installPlugin in interface BrokerPlugin

Throws:

java.lang.Exception