public class JavaRuntimeConfigurationBroker extends AbstractRuntimeConfigurationBroker
Modifier and Type | Field and Description |
---|---|
static org.slf4j.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(ActiveMQDestination destination) |
void |
addNewPolicyEntry(PolicyEntry addition) |
protected boolean |
containsDestination(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) |
void |
modifyPolicyEntry(PolicyEntry existing,
boolean createOrReplace,
Set<String> includedProperties)
This method will modify an existing policy entry that matches the destination
set on the PolicyEntry passed in.
|
void |
removeNetworkConnector(DiscoveryNetworkConnector existingCandidate) |
void |
setDestinations(ActiveMQDestination[] destinations) |
void |
setVirtualDestinations(VirtualDestination[] virtualDestinations) |
void |
setVirtualDestinations(VirtualDestination[] virtualDestinations,
boolean applyImmediately)
Set the virtual destinations and apply immediately, instead of waiting for a new
destination or connection to trigger the work.
|
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, getNext, 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 JavaRuntimeConfigurationBroker(Broker next)
next
- public void setVirtualDestinations(VirtualDestination[] virtualDestinations)
public void setVirtualDestinations(VirtualDestination[] virtualDestinations, boolean applyImmediately) throws Exception
virtualDestinations
- applyImmediately
- Exception
public void setDestinations(ActiveMQDestination[] destinations)
protected boolean containsDestination(ActiveMQDestination destination) throws Exception
Exception
public void addNewDestination(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)
public void modifyPolicyEntry(PolicyEntry existing, boolean createOrReplace, Set<String> includedProperties)
existing
- createIfAbsent
- includedProperties
- - optional list of properties to apply retrospectivelypublic void updateSimpleAuthenticationPlugin(SimpleAuthenticationPlugin updatedPlugin)
public void updateAuthorizationMap(AuthorizationMap authorizationMap)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.