public class JavaRuntimeConfigurationBroker extends AbstractRuntimeConfigurationBroker
Modifier and Type | Field and Description |
---|---|
static Logger |
LOG |
addConnectionBarrier, addConnectionWork, addDestinationBarrier, addDestinationWork, infoString, monitorTask, objectName
next
Constructor and Description |
---|
JavaRuntimeConfigurationBroker(Broker next) |
Modifier and Type | Method and Description |
---|---|
void |
addNetworkConnector(DiscoveryNetworkConnector nc) |
void |
addNewDestination(org.apache.activemq.command.ActiveMQDestination destination) |
void |
addNewPolicyEntry(PolicyEntry addition) |
protected void |
applyRetrospectively(PolicyEntry updatedEntry) |
protected boolean |
containsDestination(org.apache.activemq.command.ActiveMQDestination destination) |
void |
modifyPolicyEntry(PolicyEntry existing)
This method will modify an existing policy entry that matches the destination
set on the PolicyEntry passed in.
|
void |
modifyPolicyEntry(PolicyEntry existing,
boolean createOrReplace)
This method will modify an existing policy entry that matches the destination
set on the PolicyEntry passed in.
|
void |
removeNetworkConnector(DiscoveryNetworkConnector existingCandidate) |
void |
setDestinations(org.apache.activemq.command.ActiveMQDestination[] destinations) |
void |
setVirtualDestinations(VirtualDestination[] virtualDestinations) |
void |
updateAuthorizationMap(AuthorizationMap authorizationMap) |
void |
updateNetworkConnector(DiscoveryNetworkConnector nc) |
void |
updateSimpleAuthenticationPlugin(SimpleAuthenticationPlugin updatedPlugin) |
addConnection, addDestination, applyDestinationWork, debug, filterPasswords, info, info, registerMbean, start, stop, 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
public JavaRuntimeConfigurationBroker(Broker next)
next
- public void setVirtualDestinations(VirtualDestination[] virtualDestinations)
public void setDestinations(org.apache.activemq.command.ActiveMQDestination[] destinations)
protected boolean containsDestination(org.apache.activemq.command.ActiveMQDestination destination) throws Exception
Exception
public void addNewDestination(org.apache.activemq.command.ActiveMQDestination destination)
public void addNetworkConnector(DiscoveryNetworkConnector nc)
public void updateNetworkConnector(DiscoveryNetworkConnector nc)
public void removeNetworkConnector(DiscoveryNetworkConnector existingCandidate)
public void addNewPolicyEntry(PolicyEntry addition)
public void modifyPolicyEntry(PolicyEntry existing)
existing
- public void modifyPolicyEntry(PolicyEntry existing, boolean createOrReplace)
existing
- createIfAbsent
- protected void applyRetrospectively(PolicyEntry updatedEntry)
public void updateSimpleAuthenticationPlugin(SimpleAuthenticationPlugin updatedPlugin)
public void updateAuthorizationMap(AuthorizationMap authorizationMap)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.