Package org.apache.activemq.plugin

Class AbstractRuntimeConfigurationBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker

All Implemented Interfaces:

Broker, Region, Service

Direct Known Subclasses:

JavaRuntimeConfigurationBroker, RuntimeConfigurationBroker

public class AbstractRuntimeConfigurationBroker
extends BrokerFilter

Field Summary

Fields

Modifier and Type	Field	Description
protected ReentrantReadWriteLock	addConnectionBarrier
protected ConcurrentLinkedQueue<Runnable>	addConnectionWork
protected ReentrantReadWriteLock	addDestinationBarrier
protected ConcurrentLinkedQueue<Runnable>	addDestinationWork
protected String	infoString
static org.slf4j.Logger	LOG
protected Runnable	monitorTask
protected ObjectName	objectName

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

next

Constructor Summary

Constructors

Constructor	Description
AbstractRuntimeConfigurationBroker(Broker next)

Method Summary

Modifier and Type	Method	Description
void	addConnection(ConnectionContext context, ConnectionInfo info)	A client is establishing a connection with the broker.
Destination	addDestination(ConnectionContext context, ActiveMQDestination destination, boolean createIfTemporary)	Used to create a destination.
protected void	applyDestinationWork()	Apply the destination work immediately instead of waiting for a connection add or destination add
void	debug(String s)
protected String	filterPasswords(Object toEscape)
void	info(String s)
void	info(String s, Throwable t)
protected void	registerMbean()
void	start()
void	stop()
protected void	unregisterMbean()

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

acknowledge, addBroker, 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, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, virtualDestinationAdded, virtualDestinationRemoved

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

addDestinationBarrier

protected final ReentrantReadWriteLock addDestinationBarrier

addConnectionBarrier

protected final ReentrantReadWriteLock addConnectionBarrier

monitorTask

protected Runnable monitorTask

addDestinationWork

protected ConcurrentLinkedQueue<Runnable> addDestinationWork

addConnectionWork

protected ConcurrentLinkedQueue<Runnable> addConnectionWork

objectName

protected ObjectName objectName

infoString

protected String infoString

Constructor Detail

AbstractRuntimeConfigurationBroker

public AbstractRuntimeConfigurationBroker(Broker next)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface Service

Overrides:

start in class BrokerFilter

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface Service

Overrides:

stop in class BrokerFilter

Throws:

Exception

registerMbean

protected void registerMbean()

unregisterMbean

protected void unregisterMbean()

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 BrokerFilter

destination - the destination to create.

Returns:

TODO

Throws:

Exception - TODO

addConnection

public void addConnection(ConnectionContext context,
                          ConnectionInfo info)
                   throws Exception

Description copied from interface: Broker

A client is establishing a connection with the broker.

Specified by:

addConnection in interface Broker

Overrides:

addConnection in class BrokerFilter

Throws:

Exception - TODO

applyDestinationWork

protected void applyDestinationWork()
                             throws Exception

Apply the destination work immediately instead of waiting for a connection add or destination add

Throws:

Exception

debug

public void debug(String s)

info

public void info(String s)

info

public void info(String s,
                 Throwable t)

filterPasswords

protected String filterPasswords(Object toEscape)