public class AbstractRuntimeConfigurationBroker extends BrokerFilter
Modifier and Type | Field and 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 |
next
Constructor and Description |
---|
AbstractRuntimeConfigurationBroker(Broker next) |
Modifier and Type | Method and Description |
---|---|
void |
addConnection(ConnectionContext context,
org.apache.activemq.command.ConnectionInfo info) |
Destination |
addDestination(ConnectionContext context,
org.apache.activemq.command.ActiveMQDestination destination,
boolean createIfTemporary) |
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() |
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
protected final ReentrantReadWriteLock addDestinationBarrier
protected final ReentrantReadWriteLock addConnectionBarrier
protected Runnable monitorTask
protected ConcurrentLinkedQueue<Runnable> addDestinationWork
protected ConcurrentLinkedQueue<Runnable> addConnectionWork
protected ObjectName objectName
protected String infoString
public AbstractRuntimeConfigurationBroker(Broker next)
public void start() throws Exception
start
in interface org.apache.activemq.Service
start
in class BrokerFilter
Exception
public void stop() throws Exception
stop
in interface org.apache.activemq.Service
stop
in class BrokerFilter
Exception
protected void registerMbean()
protected void unregisterMbean()
public Destination addDestination(ConnectionContext context, org.apache.activemq.command.ActiveMQDestination destination, boolean createIfTemporary) throws Exception
addDestination
in interface Region
addDestination
in class BrokerFilter
Exception
public void addConnection(ConnectionContext context, org.apache.activemq.command.ConnectionInfo info) throws Exception
addConnection
in interface Broker
addConnection
in class BrokerFilter
Exception
protected void applyDestinationWork() throws Exception
Exception
protected String filterPasswords(Object toEscape)
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.