public class RuntimeConfigurationBroker extends AbstractRuntimeConfigurationBroker
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
static String |
objectNamePropsAppendage |
addConnectionBarrier, addConnectionWork, addDestinationBarrier, addDestinationWork, infoString, monitorTask, objectName
next
Constructor and Description |
---|
RuntimeConfigurationBroker(Broker next) |
Modifier and Type | Method and Description |
---|---|
long |
getCheckPeriod() |
org.springframework.core.io.Resource |
getConfigToMonitor() |
long |
getLastModified() |
protected void |
registerMbean() |
void |
setCheckPeriod(long checkPeriod) |
void |
start() |
protected void |
unregisterMbean() |
String |
updateNow() |
addConnection, addDestination, applyDestinationWork, debug, filterPasswords, info, info, stop
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, virtualDestinationAdded, virtualDestinationRemoved
public static final org.slf4j.Logger LOG
public static final String objectNamePropsAppendage
public RuntimeConfigurationBroker(Broker next)
public void start() throws Exception
start
in interface org.apache.activemq.Service
start
in class AbstractRuntimeConfigurationBroker
Exception
protected void registerMbean()
registerMbean
in class AbstractRuntimeConfigurationBroker
protected void unregisterMbean()
unregisterMbean
in class AbstractRuntimeConfigurationBroker
public long getLastModified()
public org.springframework.core.io.Resource getConfigToMonitor()
public long getCheckPeriod()
public void setCheckPeriod(long checkPeriod)
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.