org.apache.activemq.plugin.java

Class JavaRuntimeConfigurationBroker

java.lang.Object

org.apache.activemq.broker.BrokerFilter

org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker

org.apache.activemq.plugin.java.JavaRuntimeConfigurationBroker

All Implemented Interfaces:

Broker, Region, Service

public class JavaRuntimeConfigurationBroker
extends AbstractRuntimeConfigurationBroker

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Fields inherited from class org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker

addConnectionBarrier, addConnectionWork, addDestinationBarrier, addDestinationWork, infoString, monitorTask, objectName

Fields inherited from class org.apache.activemq.broker.BrokerFilter

next

Constructor Summary

Constructors

Constructor and Description
JavaRuntimeConfigurationBroker(Broker next)

Method Summary

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)

Methods inherited from class org.apache.activemq.plugin.AbstractRuntimeConfigurationBroker

addConnection, addDestination, applyDestinationWork, debug, filterPasswords, info, info, registerMbean, start, stop, unregisterMbean

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, 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

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

Constructor Detail

JavaRuntimeConfigurationBroker

public JavaRuntimeConfigurationBroker(Broker next)

Parameters:

next -

Method Detail

setVirtualDestinations

public void setVirtualDestinations(VirtualDestination[] virtualDestinations)

setVirtualDestinations

public void setVirtualDestinations(VirtualDestination[] virtualDestinations,
                                   boolean applyImmediately)
                            throws Exception

Set the virtual destinations and apply immediately, instead of waiting for a new destination or connection to trigger the work.

Parameters:

virtualDestinations -

applyImmediately -

Throws:

Exception

setDestinations

public void setDestinations(ActiveMQDestination[] destinations)

containsDestination

protected boolean containsDestination(ActiveMQDestination destination)
                               throws Exception

Throws:

Exception

addNewDestination

public void addNewDestination(ActiveMQDestination destination)

addNetworkConnector

public void addNetworkConnector(DiscoveryNetworkConnector nc)

updateNetworkConnector

public void updateNetworkConnector(DiscoveryNetworkConnector nc)

removeNetworkConnector

public void removeNetworkConnector(DiscoveryNetworkConnector existingCandidate)

addNewPolicyEntry

public void addNewPolicyEntry(PolicyEntry addition)

modifyPolicyEntry

public void modifyPolicyEntry(PolicyEntry existing)

This method will modify an existing policy entry that matches the destination set on the PolicyEntry passed in. The PolicyEntry reference must already be in the PolicyMap or it won't be updated. To modify the entry the best way is to look up the existing PolicyEntry from the PolicyMap, make changes to it, and pass it to this method to apply. To create or replace an existing entry (if the destination matches), see {@link #modifyPolicyEntry(PolicyEntry, boolean)

Parameters:

existing -

modifyPolicyEntry

public void modifyPolicyEntry(PolicyEntry existing,
                              boolean createOrReplace)

modifyPolicyEntry

public 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. If createOrReplace is true, a new policy will be created if it doesn't exist and a policy will be replaced in the PolicyMap, versus modified, if it is a different reference but the destinations for the Policy match. If createOrReplace is false, the policy update will only be applied if the PolicyEntry reference already exists in the PolicyMap. includedProperties is a list of properties that will be applied retrospectively. If the list is null, then all properties on the policy will be reapplied to the destination. This allows the ability to limit which properties are applied to existing destinations.

Parameters:

existing -

createIfAbsent -

includedProperties - - optional list of properties to apply retrospectively

updateSimpleAuthenticationPlugin

public void updateSimpleAuthenticationPlugin(SimpleAuthenticationPlugin updatedPlugin)

updateAuthorizationMap

public void updateAuthorizationMap(AuthorizationMap authorizationMap)