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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RuntimeConfigurationBroker.PropertiesPlaceHolderUtil

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG
static java.lang.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.
long	getCheckPeriod()
org.springframework.core.io.Resource	getConfigToMonitor()
long	getLastModified()
void	setCheckPeriod(long checkPeriod)
void	start()
void	stop()
java.lang.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, 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 org.slf4j.Logger LOG

objectNamePropsAppendage

public static final java.lang.String objectNamePropsAppendage

See Also:

Constant Field Values

Constructor Detail

RuntimeConfigurationBroker

public RuntimeConfigurationBroker(Broker next)

Method Detail

start

public void start()
           throws java.lang.Exception

Specified by:

start in interface Service

Overrides:

start in class BrokerFilter

Throws:

java.lang.Exception

stop

public void stop()
          throws java.lang.Exception

Specified by:

stop in interface Service

Overrides:

stop in class BrokerFilter

Throws:

java.lang.Exception

addDestination

public Destination addDestination(ConnectionContext context,
                         ActiveMQDestination destination,
                         boolean createIfTemporary)
                           throws java.lang.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:

java.lang.Exception - TODO

addConnection

public void addConnection(ConnectionContext context,
                 ConnectionInfo info)
                   throws java.lang.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:

java.lang.Exception - TODO

updateNow

public java.lang.String updateNow()

getLastModified

public long getLastModified()

getConfigToMonitor

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

getCheckPeriod

public long getCheckPeriod()

setCheckPeriod

public void setCheckPeriod(long checkPeriod)