org.apache.activemq.broker.util

Class DestinationsPlugin

java.lang.Object

org.apache.activemq.broker.MutableBrokerFilter

org.apache.activemq.broker.BrokerPluginSupport

org.apache.activemq.broker.util.DestinationsPlugin

All Implemented Interfaces:

Broker, BrokerPlugin, Region, Service

public class DestinationsPlugin
extends BrokerPluginSupport

A simple plugin that can be used to export/import runtime destinations. It's useful in security constrained environments where you want to create destinations only through the management APIs and be able to replicate them to another broker

Field Summary

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

next

Constructor Summary

Constructors

Constructor and Description
DestinationsPlugin()

Method Summary

Methods

Modifier and Type	Method and Description
Destination	addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary) Used to create a destination.
protected void	exportDestinations()
File	getLocation()
protected void	importDestinations()
void	removeDestination(ConnectionContext context, ActiveMQDestination destination, long timeout) Used to destroy a destination.
void	setLocation(File location)
void	start()
void	stop()

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

installPlugin

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

acknowledge, addBroker, addConnection, addConsumer, 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, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, setNext, slowConsumer

Methods inherited from class java.lang.Object

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

Constructor Detail

DestinationsPlugin

public DestinationsPlugin()

Method Detail

addDestination

public Destination addDestination(ConnectionContext context,
                         ActiveMQDestination destination,
                         boolean createIfTemporary)
                           throws Exception

Description copied from interface: Region

Used to create a destination. Usually, this method is invoked as a side-effect of sending a message to a destination that does not exist yet.

Specified by:

addDestination in interface Region

Overrides:

addDestination in class MutableBrokerFilter

destination - the destination to create.

Returns:

TODO

Throws:

Exception - TODO

removeDestination

public void removeDestination(ConnectionContext context,
                     ActiveMQDestination destination,
                     long timeout)
                       throws Exception

Description copied from interface: Region

Used to destroy a destination. This should try to quiesce use of the destination up to the timeout allotted time before removing the destination. This will remove all persistent messages associated with the destination.

Specified by:

removeDestination in interface Region

Overrides:

removeDestination in class MutableBrokerFilter

Parameters:

context - the environment the operation is being executed under.

destination - what is being removed from the broker.

timeout - the max amount of time to wait for the destination to quiesce

Throws:

Exception - TODO

start

public void start()
           throws Exception

Specified by:

start in interface Service

Overrides:

start in class BrokerPluginSupport

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Service

Overrides:

stop in class BrokerPluginSupport

Throws:

Exception

importDestinations

protected void importDestinations()
                           throws Exception

Throws:

Exception

exportDestinations

protected void exportDestinations()
                           throws Exception

Throws:

Exception

getLocation

public File getLocation()

setLocation

public void setLocation(File location)