org.apache.activemq.plugin

Class RuntimeConfigurationBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

org.apache.activemq.plugin.RuntimeConfigurationBroker

All Implemented Interfaces:

Broker, Region, Service

public class RuntimeConfigurationBroker
extends BrokerFilter

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentLinkedQueue<Runnable>	addConnectionWork
protected ConcurrentLinkedQueue<Runnable>	addDestinationWork
static Logger	LOG
static String	objectNamePropsAppendage

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

next

Constructor Summary

Constructors

Constructor and Description
RuntimeConfigurationBroker(Broker next)

Method Summary

Methods

Modifier and Type	Method and 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	debug(String s)
long	getCheckPeriod()
org.springframework.core.io.Resource	getConfigToMonitor()
long	getLastModified()
protected void	info(String s)
protected void	info(String s, Throwable t)
void	setCheckPeriod(long checkPeriod)
void	start()
void	stop()
String	updateNow()

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, 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

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final Logger LOG

objectNamePropsAppendage

public static final String objectNamePropsAppendage

See Also:

Constant Field Values

addDestinationWork

protected ConcurrentLinkedQueue<Runnable> addDestinationWork

addConnectionWork

protected ConcurrentLinkedQueue<Runnable> addConnectionWork

Constructor Detail

RuntimeConfigurationBroker

public RuntimeConfigurationBroker(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

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

updateNow

public String updateNow()

debug

protected void debug(String s)

info

protected void info(String s)

info

protected void info(String s,
        Throwable t)

getLastModified

public long getLastModified()

getConfigToMonitor

public org.springframework.core.io.Resource getConfigToMonitor()

getCheckPeriod

public long getCheckPeriod()

setCheckPeriod

public void setCheckPeriod(long checkPeriod)