Package org.apache.activemq.artemis.core.server.impl

Class ActiveMQServerImpl

java.lang.Object

org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl

All Implemented Interfaces:

ActiveMQComponent, ActiveMQServer, ServiceComponent

public class ActiveMQServerImpl
extends Object
implements ActiveMQServer

The ActiveMQ Artemis server implementation

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	ActiveMQServerImpl.DefaultCriticalErrorListener

Nested classes/interfaces inherited from interface org.apache.activemq.artemis.core.server.ActiveMQServer

ActiveMQServer.SERVER_STATE

Field Summary

Fields

Modifier and Type	Field	Description
protected ExecutorFactory	executorFactory
static final String	GENERIC_IGNORED_FILTER	Deprecated. Replaced by Filter.GENERIC_IGNORED_FILTER
static final String	INTERNAL_NAMING_PREFIX
protected final IOCriticalErrorListener	ioCriticalErrorListener
protected ExecutorFactory	ioExecutorFactory	This is a thread pool for io tasks only.
protected ExecutorFactory	pageExecutorFactory	This is a thread pool for page only tasks only.
protected ExecutorService	pageExecutorPool
protected ScheduledExecutorService	scheduledPool

Constructor Summary

Constructors

Constructor	Description
ActiveMQServerImpl()
ActiveMQServerImpl(Configuration configuration)
ActiveMQServerImpl(Configuration configuration, MBeanServer mbeanServer)
ActiveMQServerImpl(Configuration configuration, MBeanServer mbeanServer, ActiveMQSecurityManager securityManager)
ActiveMQServerImpl(Configuration configuration, MBeanServer mbeanServer, ActiveMQSecurityManager securityManager, ActiveMQServer parentServer)
ActiveMQServerImpl(Configuration configuration, MBeanServer mbeanServer, ActiveMQSecurityManager securityManager, ActiveMQServer parentServer, ServiceRegistry serviceRegistry)
ActiveMQServerImpl(Configuration configuration, ActiveMQServer parentServer)
ActiveMQServerImpl(Configuration configuration, ActiveMQSecurityManager securityManager)

Method Summary

Modifier and Type	Method	Description
void	addActivationParam(String key, Object val)
boolean	addAddressInfo(AddressInfo addressInfo)	Add the AddressInfo to the broker
boolean	addClientConnection(String clientId, boolean unique)
void	addExternalComponent(ActiveMQComponent externalComponent, boolean start)	Adding external components is allowed only if the stateisn't ActiveMQServer.SERVER_STATE.STOPPED or ActiveMQServer.SERVER_STATE.STOPPING.
AddressInfo	addOrUpdateAddressInfo(AddressInfo addressInfo)	A convenience method to combine the functionality of addAddressInfo and updateAddressInfo.
void	addProtocolManagerFactory(ProtocolManagerFactory factory)	add a ProtocolManagerFactory to be used.
AddressQueryResult	addressQuery(SimpleString name)
void	addScaledDownNode(SimpleString scaledDownNodeId)
void	autoRemoveAddressInfo(SimpleString address, SecurityAuth auth)	Remove an AddressInfo from the broker.
BindingQueryResult	bindingQuery(SimpleString address, boolean newFQQN)
void	callActivationFailureListeners(Exception e)	Alert activation failure listeners of a failure.
void	callBrokerAddressPlugins(ActiveMQPluginRunnable<ActiveMQServerAddressPlugin> pluginRun)
void	callBrokerAMQPFederationPlugins(ActiveMQPluginRunnable<AMQPFederationBrokerPlugin> pluginRun)
void	callBrokerBindingPlugins(ActiveMQPluginRunnable<ActiveMQServerBindingPlugin> pluginRun)
void	callBrokerBridgePlugins(ActiveMQPluginRunnable<ActiveMQServerBridgePlugin> pluginRun)
void	callBrokerConnectionPlugins(ActiveMQPluginRunnable<ActiveMQServerConnectionPlugin> pluginRun)
void	callBrokerConsumerPlugins(ActiveMQPluginRunnable<ActiveMQServerConsumerPlugin> pluginRun)
void	callBrokerCriticalPlugins(ActiveMQPluginRunnable<ActiveMQServerCriticalPlugin> pluginRun)
void	callBrokerFederationPlugins(ActiveMQPluginRunnable<ActiveMQServerFederationPlugin> pluginRun)
void	callBrokerMessagePlugins(ActiveMQPluginRunnable<ActiveMQServerMessagePlugin> pluginRun)
boolean	callBrokerMessagePluginsCanAccept(ServerConsumer serverConsumer, MessageReference messageReference)
void	callBrokerPlugins(ActiveMQPluginRunnable pluginRun)
void	callBrokerQueuePlugins(ActiveMQPluginRunnable<ActiveMQServerQueuePlugin> pluginRun)
void	callBrokerResourcePlugins(ActiveMQPluginRunnable<ActiveMQServerResourcePlugin> pluginRun)
void	callBrokerSessionPlugins(ActiveMQPluginRunnable<ActiveMQServerSessionPlugin> pluginRun)
void	callPostQueueCreationCallbacks(SimpleString queueName)
void	callPostQueueDeletionCallbacks(SimpleString address, SimpleString queueName)
boolean	checkBrokerIsNotColocated(String nodeId)
void	checkJournalDirectory()	Check if journal directory exists or create it (if configured to do so)
void	checkQueueCreationLimit(String username)
void	clearAddressCache()
void	completeActivation(boolean replicated)
ActiveMQServer	createBackupServer(Configuration configuration)
ServerSession	createInternalSession(String name, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString,RoutingType> prefixes, String securityDomain, boolean isLegacyProducer)	This is to be used in places where security is bypassed, like internal sessions, broker connections, etc...
protected NodeManager	createNodeManager(File directory, boolean replicatingBackup)
PagingManager	createPagingManager()
Queue	createQueue(QueueConfiguration queueConfiguration)	Overloaded version of ActiveMQServer.createQueue(QueueConfiguration, boolean) where the boolean parameter is always false (i.e. if the queue already exists then an exception will be thrown).
Queue	createQueue(QueueConfiguration queueConfiguration, boolean ignoreIfExists)	This method creates a queue based on the QueueConfiguration input.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString user, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, long ringSize)	Deprecated.
Queue	createQueue(SimpleString address, RoutingType routingType, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
Queue	createQueue(AddressInfo addrInfo, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean ignoreIfExists, boolean transientQueue, boolean autoCreated, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount, boolean autoCreateAddress, boolean configurationManaged, long ringSize)	Deprecated.
Queue	createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean lastValue, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress)	Deprecated.
Queue	createQueue(AddressInfo addressInfo, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, SimpleString groupFirstKey, Boolean lastValue, SimpleString lastValueKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, Boolean autoDelete, Long autoDeleteDelay, Long autoDeleteMessageCount, boolean autoCreateAddress, Long ringSize)	Deprecated.
ServerSession	createSession(String name, String username, String password, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context, Map<SimpleString,RoutingType> prefixes, String securityDomain, String validatedUser, boolean isLegacyProducer)
void	createSharedQueue(QueueConfiguration queueConfiguration)	This method is essentially the same as ActiveMQServer.createQueue(QueueConfiguration, boolean) with a few key exceptions.
void	createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable)	Deprecated.
void	createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean lastValue)	Deprecated.
void	createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount)	Deprecated.
void	createSharedQueue(SimpleString address, RoutingType routingType, SimpleString name, SimpleString filterString, SimpleString user, boolean durable, int maxConsumers, boolean purgeOnNoConsumers, boolean exclusive, boolean groupRebalance, int groupBuckets, SimpleString groupFirstKey, boolean lastValue, SimpleString lastValueKey, boolean nonDestructive, int consumersBeforeDispatch, long delayBeforeDispatch, boolean autoDelete, long autoDeleteDelay, long autoDeleteMessageCount)	Deprecated.
protected StorageManager	createStorageManager()	This method is protected as it may be used as a hook for creating a custom storage manager (on tests for instance)
boolean	deployBridge(BridgeConfiguration config)
Divert	deployDivert(DivertConfiguration config)
void	deployFederation(FederationConfiguration config)
Queue	deployQueue(String address, String resourceName, String filterString, boolean durable, boolean temporary)	Deprecated.
Queue	deployQueue(SimpleString address, SimpleString resourceName, SimpleString filterString, boolean durable, boolean temporary)	Deprecated.
String	describe()
void	destroyBridge(String name)
String	destroyConnectionWithSessionMetadata(String metaKey, String parameterValue)
void	destroyDivert(SimpleString name)
void	destroyDivert(SimpleString name, boolean deleteFromStorage)
void	destroyQueue(SimpleString queueName)
void	destroyQueue(SimpleString queueName, SecurityAuth session)
void	destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount)
void	destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers)
void	destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean forceAutoDeleteAddress)
void	destroyQueue(SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean forceAutoDeleteAddress, boolean checkMessageCount)
final void	fail(boolean failoverOnServerShutdown)
Set<ActivateCallback>	getActivateCallbacks()
Activation	getActivation()
ActiveMQServerControlImpl	getActiveMQServerControl()	Returns the resource to manage this ActiveMQ Artemis server.
AddressInfo	getAddressInfo(SimpleString address)
HierarchicalRepository<AddressSettings>	getAddressSettingsRepository()
Runnable	getAfterActivationCreated()	A Callback for tests
BackupManager	getBackupManager()
List<ActiveMQServerAddressPlugin>	getBrokerAddressPlugins()
List<AMQPFederationBrokerPlugin>	getBrokerAMQPFederationPlugins()
List<ActiveMQServerBindingPlugin>	getBrokerBindingPlugins()
List<ActiveMQServerBridgePlugin>	getBrokerBridgePlugins()
protected BrokerConnection	getBrokerConnection(String name)
List<ActiveMQServerConnectionPlugin>	getBrokerConnectionPlugins()
Collection<BrokerConnection>	getBrokerConnections()
List<ActiveMQServerConsumerPlugin>	getBrokerConsumerPlugins()
List<ActiveMQServerCriticalPlugin>	getBrokerCriticalPlugins()
List<ActiveMQServerFederationPlugin>	getBrokerFederationPlugins()
List<ActiveMQServerMessagePlugin>	getBrokerMessagePlugins()
List<ActiveMQServerBasePlugin>	getBrokerPlugins()
List<ActiveMQServerQueuePlugin>	getBrokerQueuePlugins()
List<ActiveMQServerResourcePlugin>	getBrokerResourcePlugins()
List<ActiveMQServerSessionPlugin>	getBrokerSessionPlugins()
ClusterManager	getClusterManager()
Configuration	getConfiguration()
int	getConnectionCount()
ConnectionRouterManager	getConnectionRouterManager()
ConnectorsService	getConnectorsService()
CriticalAnalyzer	getCriticalAnalyzer()
double	getDiskStoreUsage()
ExecutorFactory	getExecutorFactory()
List<ActiveMQComponent>	getExternalComponents()
FederationManager	getFederationManager()
GroupingHandler	getGroupingHandler()
HAPolicy	getHAPolicy()
String	getIdentity()
String	getInternalNamingPrefix()
IOCriticalErrorListener	getIoCriticalErrorListener()	The server has a default listener that will propagate errors to registered listeners.
ExecutorFactory	getIOExecutorFactory()
ManagementService	getManagementService()
MBeanServer	getMBeanServer()
MetricsManager	getMetricsManager()
MirrorController	getMirrorController()
MirrorRegistry	getMirrorRegistry()
FileStoreMonitor	getMonitor()
NetworkHealthCheck	getNetworkHealthCheck()
SimpleString	getNodeID()
NodeManager	getNodeManager()
PagingManager	getPagingManager()
protected PagingStoreFactory	getPagingStoreFactory()
int	getPendingMirrorAcks()
PostOffice	getPostOffice()
int	getQueueCountForUser(String username)
QueueFactory	getQueueFactory()
ReloadManager	getReloadManager()
RemotingService	getRemotingService()
ReplicationManager	getReplicationManager()
ResourceManager	getResourceManager()
String	getRuntimeTempQueueNamespace(boolean temporary)
ScheduledExecutorService	getScheduledPool()
ActiveMQSecurityManager	getSecurityManager()
HierarchicalRepository<Set<Role>>	getSecurityRepository()
SecurityStore	getSecurityStore()
ServiceRegistry	getServiceRegistry()
ServerSession	getSessionByID(String sessionName)
int	getSessionCount()
Set<ServerSession>	getSessions()
List<ServerSession>	getSessions(String connectionID)
ActiveMQServer.SERVER_STATE	getState()
String	getStatus()
StorageManager	getStorageManager()
ExecutorService	getThreadPool()
long	getTotalConnectionCount()
long	getTotalConsumerCount()
long	getTotalMessageCount()
long	getTotalMessagesAcknowledged()
long	getTotalMessagesAdded()
long	getTotalSessionCount()
String	getUptime()
long	getUptimeMillis()
Version	getVersion()
boolean	hasBrokerAddressPlugins()
boolean	hasBrokerAMQPFederationPlugins()
boolean	hasBrokerBindingPlugins()
boolean	hasBrokerBridgePlugins()
boolean	hasBrokerConnectionPlugins()
boolean	hasBrokerConsumerPlugins()
boolean	hasBrokerCriticalPlugins()
boolean	hasBrokerFederationPlugins()
boolean	hasBrokerMessagePlugins()
boolean	hasBrokerPlugins()
boolean	hasBrokerQueuePlugins()
boolean	hasBrokerResourcePlugins()
boolean	hasBrokerSessionPlugins()
boolean	hasScaledDown(SimpleString scaledDownNodeId)
protected void	initializeCriticalAnalyzer()
void	injectMonitor(FileStoreMonitor storeMonitor)	This method exists for a possibility of test cases replacing the FileStoreMonitor for an extension that would for instance pretend a disk full on certain tests.
void	installMirrorController(MirrorController mirrorController)
protected ServerSessionImpl	internalCreateSession(String name, String username, String password, String validatedUser, int minLargeMessageSize, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, OperationContext context, boolean autoCreateQueues, Map<SimpleString,RoutingType> prefixes, String securityDomain, boolean isLegacyProducer)
void	interruptActivationThread(NodeManager nodeManagerInUse)
boolean	isActive()
boolean	isAddressBound(String address)	Returns true if there is a binding for this address (i.e. if there is a created queue).
boolean	isRebuildCounters()	should the server rebuild page counters upon startup. this will be useful on testing or an embedded broker scenario
boolean	isReplicaSync()	Returns whether the initial replication synchronization process with the backup server is complete; applicable for either the primary or backup server.
boolean	isStarted()
Queue	locateQueue(String address, String queue)
Queue	locateQueue(SimpleString queueName)
void	lockActivation()	it will hold a lock for the activation.
ServerSession	lookupSession(String key, String value)	Returns a session containing the meta-key and meata-value.
AutoCloseable	managementLock()
OperationContext	newOperationContext()
QueueQueryResult	queueQuery(SimpleString name)
void	registerActivateCallback(ActivateCallback callback)
void	registerActivationFailureListener(ActivationFailureListener listener)	Register a listener to detect problems during activation
void	registerBrokerConnection(BrokerConnection brokerConnection)
void	registerBrokerPlugin(ActiveMQServerBasePlugin plugin)
void	registerBrokerPlugins(List<ActiveMQServerBasePlugin> plugins)
void	registerIOCriticalErrorListener(IOCriticalErrorListener listener)	Register a listener to detect I/O Critical errors
void	registerPostQueueCreationCallback(PostQueueCreationCallback callback)	Register a PostQueueDeletionCallback to be called after a queue is created.
void	registerPostQueueDeletionCallback(PostQueueDeletionCallback callback)	Register a PostQueueDeletionCallback to be called after a queue is deleted.
void	registerQueueOnManagement(Queue queue)	Register a queue on the management registry
void	registerRecordsLoader(Consumer<RecordInfo> recordsLoader)
void	reloadConfigurationFile()
void	reloadNetworkHealthCheck()
void	removeAddressInfo(SimpleString address, SecurityAuth auth)	Remove an AddressInfo from the broker.
void	removeAddressInfo(SimpleString address, SecurityAuth auth, boolean force)	Remove an AddressInfo from the broker.
void	removeClientConnection(String clientId)
void	removeMirrorControl()
void	removeProtocolManagerFactory(ProtocolManagerFactory factory)
void	removeSession(String name)
void	replaceQueueFactory(QueueFactory factory)	For tests only, don't use this method as it's not part of the API
void	replay(Date start, Date end, String address, String target, String filter)
void	resetNodeManager()
void	scanAddresses(MirrorController mirrorController)	This method will scan all queues and addresses. it is supposed to be called before the mirrorController is started
void	setActivation(Activation activation)
ActiveMQServerImpl	setAfterActivationCreated(Runnable afterActivationCreated)	A Callback for tests
void	setGroupingHandler(GroupingHandler groupingHandler)
void	setHAPolicy(HAPolicy haPolicy)
void	setIdentity(String identity)	Sets the server identity.
void	setMBeanServer(MBeanServer mbeanServer)
void	setProperties(String fileUrltoBrokerProperties)
void	setRebuildCounters(boolean rebuildCounters)	should the server rebuild page counters upon startup. this will be useful on testing or an embedded broker scenario
void	setSecurityManager(ActiveMQSecurityManager securityManager)
void	setState(ActiveMQServer.SERVER_STATE state)
final void	start()
void	startBrokerConnection(String name)
void	stop()
void	stop(boolean isShutdown)
final void	stop(boolean failoverOnServerShutdown, boolean isExit)
void	stop(boolean failoverOnServerShutdown, boolean criticalIOError, boolean restarting)
void	stopBrokerConnection(String name)
final void	stopTheServer(boolean criticalIOError)	Stops the server in a different thread.
void	threadDump()
String	toString()
void	undeployFederation(String name)
void	unlockActivation()	it will release hold a lock for the activation.
void	unregisterActivateCallback(ActivateCallback callback)
void	unregisterActivationFailureListener(ActivationFailureListener listener)	Remove a previously registered failure listener
void	unregisterBrokerConnection(BrokerConnection brokerConnection)	Removes the given broker connection from the tracked set of active broker connection entries.
void	unRegisterBrokerPlugin(ActiveMQServerBasePlugin plugin)
void	unregisterPostQueueCreationCallback(PostQueueCreationCallback callback)	Unregister a PostQueueCreationCallback.
void	unregisterPostQueueDeletionCallback(PostQueueDeletionCallback callback)	Unregister a PostQueueDeletionCallback.
boolean	updateAddressInfo(SimpleString address, Collection<RoutingType> routingTypes)
boolean	updateAddressInfo(SimpleString address, EnumSet<RoutingType> routingTypes)	Updates an AddressInfo on the broker with the specified routing types.
Divert	updateDivert(DivertConfiguration config)
Queue	updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers)	Deprecated.
Queue	updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive)	Deprecated.
Queue	updateQueue(String name, RoutingType routingType, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, String user)	Deprecated.
Queue	updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user)	Deprecated.
Queue	updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user)	Deprecated.
Queue	updateQueue(String name, RoutingType routingType, String filterString, Integer maxConsumers, Boolean purgeOnNoConsumers, Boolean exclusive, Boolean groupRebalance, Integer groupBuckets, String groupFirstKey, Boolean nonDestructive, Integer consumersBeforeDispatch, Long delayBeforeDispatch, String user, Long ringSize)	Deprecated.
Queue	updateQueue(QueueConfiguration queueConfiguration)	Update the queue named in the QueueConfiguration with the corresponding properties.
Queue	updateQueue(QueueConfiguration queueConfiguration, boolean forceUpdate)	Update a queue's configuration.
void	updateStatus(String component, String statusJson)
String	validateUser(String username, String password, RemotingConnection connection, String securityDomain)
boolean	waitForActivation(long timeout, TimeUnit unit)	Wait for server initialization.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQServer

bindingQuery, locateQueue

Field Details

INTERNAL_NAMING_PREFIX

public static final String INTERNAL_NAMING_PREFIX

See Also:

• Constant Field Values

GENERIC_IGNORED_FILTER

@Deprecated
public static final String GENERIC_IGNORED_FILTER

Deprecated.

Replaced by Filter.GENERIC_IGNORED_FILTER

JMS Topics (which are outside of the scope of the core API) will require a dumb subscription with a dummy-filter at this current version as a way to keep its existence valid and TCK tests. That subscription needs an invalid filter, however paging needs to ignore any subscription with this filter. For that reason, this filter needs to be rejected on paging or any other component on the system, and just be ignored for any purpose It's declared here as this filter is considered a global ignore

See Also:

• Constant Field Values

scheduledPool

protected volatile ScheduledExecutorService scheduledPool

executorFactory

protected volatile ExecutorFactory executorFactory

ioExecutorFactory

protected volatile ExecutorFactory ioExecutorFactory

This is a thread pool for io tasks only. We can't use the same global executor to avoid starvations.

pageExecutorFactory

protected volatile ExecutorFactory pageExecutorFactory

This is a thread pool for page only tasks only. This is because we have to limit parallel reads on paging.

pageExecutorPool

protected volatile ExecutorService pageExecutorPool

ioCriticalErrorListener

protected final IOCriticalErrorListener ioCriticalErrorListener

Constructor Details

ActiveMQServerImpl

public ActiveMQServerImpl()

ActiveMQServerImpl

public ActiveMQServerImpl(Configuration configuration)

ActiveMQServerImpl

public ActiveMQServerImpl(Configuration configuration,
 ActiveMQServer parentServer)

ActiveMQServerImpl

public ActiveMQServerImpl(Configuration configuration,
 MBeanServer mbeanServer)

ActiveMQServerImpl

public ActiveMQServerImpl(Configuration configuration,
 ActiveMQSecurityManager securityManager)

ActiveMQServerImpl

public ActiveMQServerImpl(Configuration configuration,
 MBeanServer mbeanServer,
 ActiveMQSecurityManager securityManager)

ActiveMQServerImpl

public ActiveMQServerImpl(Configuration configuration,
 MBeanServer mbeanServer,
 ActiveMQSecurityManager securityManager,
 ActiveMQServer parentServer)

ActiveMQServerImpl

public ActiveMQServerImpl(Configuration configuration,
 MBeanServer mbeanServer,
 ActiveMQSecurityManager securityManager,
 ActiveMQServer parentServer,
 ServiceRegistry serviceRegistry)

Method Details

getReloadManager

public ReloadManager getReloadManager()

Specified by:

getReloadManager in interface ActiveMQServer

getNetworkHealthCheck

public NetworkHealthCheck getNetworkHealthCheck()

Specified by:

getNetworkHealthCheck in interface ActiveMQServer

setRebuildCounters

public void setRebuildCounters(boolean rebuildCounters)

Description copied from interface: ActiveMQServer

should the server rebuild page counters upon startup. this will be useful on testing or an embedded broker scenario

Specified by:

setRebuildCounters in interface ActiveMQServer

isRebuildCounters

public boolean isRebuildCounters()

Description copied from interface: ActiveMQServer

should the server rebuild page counters upon startup. this will be useful on testing or an embedded broker scenario

Specified by:

isRebuildCounters in interface ActiveMQServer

replay

public void replay(Date start,
 Date end,
 String address,
 String target,
 String filter)
            throws Exception

Specified by:

replay in interface ActiveMQServer

Throws:

Exception

registerRecordsLoader

public void registerRecordsLoader(Consumer<RecordInfo> recordsLoader)

Specified by:

registerRecordsLoader in interface ActiveMQServer

getAfterActivationCreated

public Runnable getAfterActivationCreated()

A Callback for tests

setAfterActivationCreated

public ActiveMQServerImpl setAfterActivationCreated(Runnable afterActivationCreated)

A Callback for tests

createNodeManager

protected NodeManager createNodeManager(File directory,
 boolean replicatingBackup)

newOperationContext

public OperationContext newOperationContext()

Specified by:

newOperationContext in interface ActiveMQServer

start

public final void start()
                 throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

reloadNetworkHealthCheck

public void reloadNetworkHealthCheck()

getCriticalAnalyzer

public CriticalAnalyzer getCriticalAnalyzer()

Specified by:

getCriticalAnalyzer in interface ActiveMQServer

setProperties

public void setProperties(String fileUrltoBrokerProperties)

Specified by:

setProperties in interface ActiveMQServer

getStatus

public String getStatus()

Specified by:

getStatus in interface ActiveMQServer

updateStatus

public void updateStatus(String component,
 String statusJson)

Specified by:

updateStatus in interface ActiveMQServer

initializeCriticalAnalyzer

protected void initializeCriticalAnalyzer()
                                   throws Exception

Throws:

Exception

unlockActivation

public void unlockActivation()

Description copied from interface: ActiveMQServer

it will release hold a lock for the activation.

Specified by:

unlockActivation in interface ActiveMQServer

lockActivation

public void lockActivation()

Description copied from interface: ActiveMQServer

it will hold a lock for the activation. This will prevent the activation from happening.

Specified by:

lockActivation in interface ActiveMQServer

setState

public void setState(ActiveMQServer.SERVER_STATE state)

Specified by:

setState in interface ActiveMQServer

getState

public ActiveMQServer.SERVER_STATE getState()

Specified by:

getState in interface ActiveMQServer

interruptActivationThread

public void interruptActivationThread(NodeManager nodeManagerInUse)
                               throws InterruptedException

Throws:

InterruptedException

resetNodeManager

public void resetNodeManager()
                      throws Exception

Throws:

Exception

getActivation

public Activation getActivation()

Specified by:

getActivation in interface ActiveMQServer

getHAPolicy

public HAPolicy getHAPolicy()

Specified by:

getHAPolicy in interface ActiveMQServer

setHAPolicy

public void setHAPolicy(HAPolicy haPolicy)

Specified by:

setHAPolicy in interface ActiveMQServer

setMBeanServer

public void setMBeanServer(MBeanServer mbeanServer)

Specified by:

setMBeanServer in interface ActiveMQServer

getMBeanServer

public MBeanServer getMBeanServer()

Specified by:

getMBeanServer in interface ActiveMQServer

setSecurityManager

public void setSecurityManager(ActiveMQSecurityManager securityManager)

Specified by:

setSecurityManager in interface ActiveMQServer

addExternalComponent

public void addExternalComponent(ActiveMQComponent externalComponent,
 boolean start)
                          throws Exception

Description copied from interface: ActiveMQServer

Adding external components is allowed only if the stateisn't ActiveMQServer.SERVER_STATE.STOPPED or ActiveMQServer.SERVER_STATE.STOPPING.

It atomically starts the externalComponent while being added if start == true.

This atomicity is necessary to prevent ActiveMQComponent.stop() to stop the component right after adding it, but before starting it.

Specified by:

addExternalComponent in interface ActiveMQServer

Throws:

IllegalStateException - if the state is ActiveMQServer.SERVER_STATE.STOPPED or ActiveMQServer.SERVER_STATE.STOPPING

Exception

getThreadPool

public ExecutorService getThreadPool()

Specified by:

getThreadPool in interface ActiveMQServer

setActivation

public void setActivation(Activation activation)

stopTheServer

public final void stopTheServer(boolean criticalIOError)

Stops the server in a different thread.

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

stop

public void stop(boolean isShutdown)
          throws Exception

Specified by:

stop in interface ServiceComponent

Throws:

Exception

addActivationParam

public void addActivationParam(String key,
 Object val)

Specified by:

addActivationParam in interface ActiveMQServer

isAddressBound

public boolean isAddressBound(String address)
                       throws Exception

Description copied from interface: ActiveMQServer

Returns true if there is a binding for this address (i.e. if there is a created queue).

Specified by:

isAddressBound in interface ActiveMQServer

Returns:

true if there is a binding for this address (i.e. if there is a created queue)

Throws:

Exception

bindingQuery

public BindingQueryResult bindingQuery(SimpleString address,
 boolean newFQQN)
                                throws Exception

Specified by:

bindingQuery in interface ActiveMQServer

Throws:

Exception

queueQuery

public QueueQueryResult queueQuery(SimpleString name)

Specified by:

queueQuery in interface ActiveMQServer

addressQuery

public AddressQueryResult addressQuery(SimpleString name)
                                throws Exception

Specified by:

addressQuery in interface ActiveMQServer

Throws:

Exception

registerBrokerConnection

public void registerBrokerConnection(BrokerConnection brokerConnection)

Specified by:

registerBrokerConnection in interface ActiveMQServer

unregisterBrokerConnection

public void unregisterBrokerConnection(BrokerConnection brokerConnection)

Description copied from interface: ActiveMQServer

Removes the given broker connection from the tracked set of active broker connection entries. Unregistering the connection results in it being forgotten and the caller is responsible for stopping the connection.

Specified by:

unregisterBrokerConnection in interface ActiveMQServer

Parameters:

brokerConnection - The broker connection that should be forgotten.

startBrokerConnection

public void startBrokerConnection(String name)
                           throws Exception

Specified by:

startBrokerConnection in interface ActiveMQServer

Throws:

Exception

getBrokerConnection

protected BrokerConnection getBrokerConnection(String name)

stopBrokerConnection

public void stopBrokerConnection(String name)
                          throws Exception

Specified by:

stopBrokerConnection in interface ActiveMQServer

Throws:

Exception

getBrokerConnections

public Collection<BrokerConnection> getBrokerConnections()

Specified by:

getBrokerConnections in interface ActiveMQServer

threadDump

public void threadDump()

Specified by:

threadDump in interface ActiveMQServer

fail

public final void fail(boolean failoverOnServerShutdown)
                throws Exception

Specified by:

fail in interface ActiveMQServer

Throws:

Exception

stop

public final void stop(boolean failoverOnServerShutdown,
 boolean isExit)
                throws Exception

Specified by:

stop in interface ActiveMQServer

Throws:

Exception

isReplicaSync

public boolean isReplicaSync()

Description copied from interface: ActiveMQServer

Returns whether the initial replication synchronization process with the backup server is complete; applicable for either the primary or backup server.

Specified by:

isReplicaSync in interface ActiveMQServer

Returns:

whether the initial replication synchronization process with the backup server is complete; applicable for either the primary or backup server

stop

public void stop(boolean failoverOnServerShutdown,
 boolean criticalIOError,
 boolean restarting)

checkBrokerIsNotColocated

public boolean checkBrokerIsNotColocated(String nodeId)

describe

public String describe()

Specified by:

describe in interface ActiveMQServer

destroyConnectionWithSessionMetadata

public String destroyConnectionWithSessionMetadata(String metaKey,
 String parameterValue)
                                            throws Exception

Specified by:

destroyConnectionWithSessionMetadata in interface ActiveMQServer

Throws:

Exception

setIdentity

public void setIdentity(String identity)

Description copied from interface: ActiveMQServer

Sets the server identity.

The identity will be exposed on logs. It may help to debug issues on the log traces and debugs.

This method was created mainly for testing but it may be used in scenarios where you need to have more than one Server inside the same VM.

Specified by:

setIdentity in interface ActiveMQServer

getIdentity

public String getIdentity()

Specified by:

getIdentity in interface ActiveMQServer

getScheduledPool

public ScheduledExecutorService getScheduledPool()

Specified by:

getScheduledPool in interface ActiveMQServer

getConfiguration

public Configuration getConfiguration()

Specified by:

getConfiguration in interface ActiveMQServer

getPagingManager

public PagingManager getPagingManager()

Specified by:

getPagingManager in interface ActiveMQServer

getRemotingService

public RemotingService getRemotingService()

Specified by:

getRemotingService in interface ActiveMQServer

getStorageManager

public StorageManager getStorageManager()

Specified by:

getStorageManager in interface ActiveMQServer

getSecurityManager

public ActiveMQSecurityManager getSecurityManager()

Specified by:

getSecurityManager in interface ActiveMQServer

getManagementService

public ManagementService getManagementService()

Specified by:

getManagementService in interface ActiveMQServer

getSecurityRepository

public HierarchicalRepository<Set<Role>> getSecurityRepository()

Specified by:

getSecurityRepository in interface ActiveMQServer

getNodeManager

public NodeManager getNodeManager()

Specified by:

getNodeManager in interface ActiveMQServer

getAddressSettingsRepository

public HierarchicalRepository<AddressSettings> getAddressSettingsRepository()

Specified by:

getAddressSettingsRepository in interface ActiveMQServer

getResourceManager

public ResourceManager getResourceManager()

Specified by:

getResourceManager in interface ActiveMQServer

getMetricsManager

public MetricsManager getMetricsManager()

Specified by:

getMetricsManager in interface ActiveMQServer

getVersion

public Version getVersion()

Specified by:

getVersion in interface ActiveMQServer

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

getClusterManager

public ClusterManager getClusterManager()

Specified by:

getClusterManager in interface ActiveMQServer

getConnectionRouterManager

public ConnectionRouterManager getConnectionRouterManager()

Specified by:

getConnectionRouterManager in interface ActiveMQServer

getBackupManager

public BackupManager getBackupManager()

createSession

public ServerSession createSession(String name,
 String username,
 String password,
 int minLargeMessageSize,
 RemotingConnection connection,
 boolean autoCommitSends,
 boolean autoCommitAcks,
 boolean preAcknowledge,
 boolean xa,
 String defaultAddress,
 SessionCallback callback,
 boolean autoCreateQueues,
 OperationContext context,
 Map<SimpleString,RoutingType> prefixes,
 String securityDomain,
 String validatedUser,
 boolean isLegacyProducer)
                            throws Exception

Specified by:

createSession in interface ActiveMQServer

Throws:

Exception

validateUser

public String validateUser(String username,
 String password,
 RemotingConnection connection,
 String securityDomain)
                    throws Exception

Specified by:

validateUser in interface ActiveMQServer

Throws:

Exception

createInternalSession

public ServerSession createInternalSession(String name,
 int minLargeMessageSize,
 RemotingConnection connection,
 boolean autoCommitSends,
 boolean autoCommitAcks,
 boolean preAcknowledge,
 boolean xa,
 String defaultAddress,
 SessionCallback callback,
 boolean autoCreateQueues,
 OperationContext context,
 Map<SimpleString,RoutingType> prefixes,
 String securityDomain,
 boolean isLegacyProducer)
                                    throws Exception

Description copied from interface: ActiveMQServer

This is to be used in places where security is bypassed, like internal sessions, broker connections, etc...

Specified by:

createInternalSession in interface ActiveMQServer

Throws:

Exception

checkQueueCreationLimit

public void checkQueueCreationLimit(String username)
                             throws Exception

Specified by:

checkQueueCreationLimit in interface ActiveMQServer

Throws:

Exception

getQueueCountForUser

public int getQueueCountForUser(String username)
                         throws Exception

Throws:

Exception

internalCreateSession

protected ServerSessionImpl internalCreateSession(String name,
 String username,
 String password,
 String validatedUser,
 int minLargeMessageSize,
 RemotingConnection connection,
 boolean autoCommitSends,
 boolean autoCommitAcks,
 boolean preAcknowledge,
 boolean xa,
 String defaultAddress,
 SessionCallback callback,
 OperationContext context,
 boolean autoCreateQueues,
 Map<SimpleString,RoutingType> prefixes,
 String securityDomain,
 boolean isLegacyProducer)
                                           throws Exception

Throws:

Exception

getSecurityStore

public SecurityStore getSecurityStore()

Specified by:

getSecurityStore in interface ActiveMQServer

removeSession

public void removeSession(String name)
                   throws Exception

Specified by:

removeSession in interface ActiveMQServer

Throws:

Exception

lookupSession

public ServerSession lookupSession(String key,
 String value)

Description copied from interface: ActiveMQServer

Returns a session containing the meta-key and meata-value.

Specified by:

lookupSession in interface ActiveMQServer

Returns:

a session containing the meta-key and meata-value

getSessions

public List<ServerSession> getSessions(String connectionID)

Specified by:

getSessions in interface ActiveMQServer

getSessions

public Set<ServerSession> getSessions()

Specified by:

getSessions in interface ActiveMQServer

isActive

public boolean isActive()

Specified by:

isActive in interface ActiveMQServer

waitForActivation

public boolean waitForActivation(long timeout,
 TimeUnit unit)
                          throws InterruptedException

Description copied from interface: ActiveMQServer

Wait for server initialization.

Specified by:

waitForActivation in interface ActiveMQServer

Returns:

true if the server was already initialized or if it was initialized within the timeout period, false otherwise.

Throws:

InterruptedException

See Also:

• CountDownLatch.await(long, java.util.concurrent.TimeUnit)

getActiveMQServerControl

public ActiveMQServerControlImpl getActiveMQServerControl()

Description copied from interface: ActiveMQServer

Returns the resource to manage this ActiveMQ Artemis server.

Specified by:

getActiveMQServerControl in interface ActiveMQServer

Returns:

the resource to manage this ActiveMQ Artemis server

getConnectionCount

public int getConnectionCount()

Specified by:

getConnectionCount in interface ActiveMQServer

getTotalConnectionCount

public long getTotalConnectionCount()

Specified by:

getTotalConnectionCount in interface ActiveMQServer

getSessionCount

public int getSessionCount()

Specified by:

getSessionCount in interface ActiveMQServer

getTotalSessionCount

public long getTotalSessionCount()

Specified by:

getTotalSessionCount in interface ActiveMQServer

getTotalMessageCount

public long getTotalMessageCount()

Specified by:

getTotalMessageCount in interface ActiveMQServer

getTotalMessagesAdded

public long getTotalMessagesAdded()

Specified by:

getTotalMessagesAdded in interface ActiveMQServer

getTotalMessagesAcknowledged

public long getTotalMessagesAcknowledged()

Specified by:

getTotalMessagesAcknowledged in interface ActiveMQServer

getTotalConsumerCount

public long getTotalConsumerCount()

Specified by:

getTotalConsumerCount in interface ActiveMQServer

getPostOffice

public PostOffice getPostOffice()

Specified by:

getPostOffice in interface ActiveMQServer

getQueueFactory

public QueueFactory getQueueFactory()

Specified by:

getQueueFactory in interface ActiveMQServer

getNodeID

public SimpleString getNodeID()

Specified by:

getNodeID in interface ActiveMQServer

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filterString,
 boolean durable,
 boolean temporary)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString user,
 SimpleString filterString,
 boolean durable,
 boolean temporary)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filter,
 boolean durable,
 boolean temporary,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filter,
 boolean durable,
 boolean temporary,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filter,
 boolean durable,
 boolean temporary,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 SimpleString groupFirstKey,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filter,
 boolean durable,
 boolean temporary,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 SimpleString groupFirstKey,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount,
 boolean autoCreateAddress,
 long ringSize)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filter,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean autoCreated,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(AddressInfo addressInfo,
 SimpleString queueName,
 SimpleString filter,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean autoCreated,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(AddressInfo addressInfo,
 SimpleString queueName,
 SimpleString filter,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean autoCreated,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive,
 Boolean lastValue,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(AddressInfo addressInfo,
 SimpleString queueName,
 SimpleString filter,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean autoCreated,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive,
 Boolean groupRebalance,
 Integer groupBuckets,
 Boolean lastValue,
 SimpleString lastValueKey,
 Boolean nonDestructive,
 Integer consumersBeforeDispatch,
 Long delayBeforeDispatch,
 Boolean autoDelete,
 Long autoDeleteDelay,
 Long autoDeleteMessageCount,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(AddressInfo addressInfo,
 SimpleString queueName,
 SimpleString filter,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean autoCreated,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive,
 Boolean groupRebalance,
 Integer groupBuckets,
 SimpleString groupFirstKey,
 Boolean lastValue,
 SimpleString lastValueKey,
 Boolean nonDestructive,
 Integer consumersBeforeDispatch,
 Long delayBeforeDispatch,
 Boolean autoDelete,
 Long autoDeleteDelay,
 Long autoDeleteMessageCount,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(AddressInfo addressInfo,
 SimpleString queueName,
 SimpleString filter,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean autoCreated,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive,
 Boolean groupRebalance,
 Integer groupBuckets,
 SimpleString groupFirstKey,
 Boolean lastValue,
 SimpleString lastValueKey,
 Boolean nonDestructive,
 Integer consumersBeforeDispatch,
 Long delayBeforeDispatch,
 Boolean autoDelete,
 Long autoDeleteDelay,
 Long autoDeleteMessageCount,
 boolean autoCreateAddress,
 Long ringSize)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filter,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean ignoreIfExists,
 boolean transientQueue,
 boolean autoCreated,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filter,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean ignoreIfExists,
 boolean transientQueue,
 boolean autoCreated,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean lastValue,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 SimpleString queueName,
 SimpleString filterString,
 boolean durable,
 boolean temporary)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createSharedQueue

@Deprecated
public void createSharedQueue(SimpleString address,
 RoutingType routingType,
 SimpleString name,
 SimpleString filterString,
 SimpleString user,
 boolean durable)
                       throws Exception

Deprecated.

Description copied from interface: ActiveMQServer

Creates a transient queue. A queue that will exist as long as there are consumers. The queue will be deleted as soon as all the consumers are removed.

Notice: the queue won't be deleted until the first consumer arrives.

Specified by:

createSharedQueue in interface ActiveMQServer

Throws:

ActiveMQInvalidTransientQueueUseException - if the shared queue already exists with a different address or filterString

NullPointerException - if address is null

Exception

createSharedQueue

@Deprecated
public void createSharedQueue(SimpleString address,
 RoutingType routingType,
 SimpleString name,
 SimpleString filterString,
 SimpleString user,
 boolean durable,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean lastValue)
                       throws Exception

Deprecated.

Specified by:

createSharedQueue in interface ActiveMQServer

Throws:

Exception

createSharedQueue

@Deprecated
public void createSharedQueue(SimpleString address,
 RoutingType routingType,
 SimpleString name,
 SimpleString filterString,
 SimpleString user,
 boolean durable,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount)
                       throws Exception

Deprecated.

Specified by:

createSharedQueue in interface ActiveMQServer

Throws:

Exception

createSharedQueue

@Deprecated
public void createSharedQueue(SimpleString address,
 RoutingType routingType,
 SimpleString name,
 SimpleString filterString,
 SimpleString user,
 boolean durable,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 SimpleString groupFirstKey,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount)
                       throws Exception

Deprecated.

Specified by:

createSharedQueue in interface ActiveMQServer

Throws:

Exception

createSharedQueue

public void createSharedQueue(QueueConfiguration queueConfiguration)
                       throws Exception

Description copied from interface: ActiveMQServer

This method is essentially the same as ActiveMQServer.createQueue(QueueConfiguration, boolean) with a few key exceptions.

If durable is true then:

• transient will be forced to false
• temporary will be forced to false

If durable is false then:

• transient will be forced to true
• temporary will be forced to true

> In all instances autoCreated will be forced to false and autoCreatedAddress will be forced to true.

The boolean passed to ActiveMQServer.createQueue(QueueConfiguration, boolean) will always be true;

Specified by:

createSharedQueue in interface ActiveMQServer

Throws:

Exception

See Also:

• ActiveMQServer.createQueue(QueueConfiguration, boolean)

locateQueue

public Queue locateQueue(SimpleString queueName)

Specified by:

locateQueue in interface ActiveMQServer

locateQueue

public Queue locateQueue(String address,
 String queue)
                  throws Exception

Specified by:

locateQueue in interface ActiveMQServer

Throws:

Exception

deployQueue

@Deprecated
public Queue deployQueue(SimpleString address,
 SimpleString resourceName,
 SimpleString filterString,
 boolean durable,
 boolean temporary)
                  throws Exception

Deprecated.

Specified by:

deployQueue in interface ActiveMQServer

Throws:

Exception

deployQueue

@Deprecated
public Queue deployQueue(String address,
 String resourceName,
 String filterString,
 boolean durable,
 boolean temporary)
                  throws Exception

Deprecated.

Specified by:

deployQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
 SecurityAuth session)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
 SecurityAuth session,
 boolean checkConsumerCount)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
 SecurityAuth session,
 boolean checkConsumerCount,
 boolean removeConsumers)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
 SecurityAuth session,
 boolean checkConsumerCount,
 boolean removeConsumers,
 boolean forceAutoDeleteAddress)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(SimpleString queueName,
 SecurityAuth session,
 boolean checkConsumerCount,
 boolean removeConsumers,
 boolean forceAutoDeleteAddress,
 boolean checkMessageCount)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

clearAddressCache

public void clearAddressCache()

Specified by:

clearAddressCache in interface ActiveMQServer

registerActivateCallback

public void registerActivateCallback(ActivateCallback callback)

Specified by:

registerActivateCallback in interface ActiveMQServer

unregisterActivateCallback

public void unregisterActivateCallback(ActivateCallback callback)

Specified by:

unregisterActivateCallback in interface ActiveMQServer

registerActivationFailureListener

public void registerActivationFailureListener(ActivationFailureListener listener)

Description copied from interface: ActiveMQServer

Register a listener to detect problems during activation

Specified by:

registerActivationFailureListener in interface ActiveMQServer

See Also:

• ActivationFailureListener

unregisterActivationFailureListener

public void unregisterActivationFailureListener(ActivationFailureListener listener)

Description copied from interface: ActiveMQServer

Remove a previously registered failure listener

Specified by:

unregisterActivationFailureListener in interface ActiveMQServer

callActivationFailureListeners

public void callActivationFailureListeners(Exception e)

Description copied from interface: ActiveMQServer

Alert activation failure listeners of a failure.

Specified by:

callActivationFailureListeners in interface ActiveMQServer

Parameters:

e - the exception that caused the activation failure

registerIOCriticalErrorListener

public void registerIOCriticalErrorListener(IOCriticalErrorListener listener)

Description copied from interface: ActiveMQServer

Register a listener to detect I/O Critical errors

Specified by:

registerIOCriticalErrorListener in interface ActiveMQServer

See Also:

• IOCriticalErrorListener

registerPostQueueCreationCallback

public void registerPostQueueCreationCallback(PostQueueCreationCallback callback)

Description copied from interface: ActiveMQServer

Register a PostQueueDeletionCallback to be called after a queue is created.

Specified by:

registerPostQueueCreationCallback in interface ActiveMQServer

Parameters:

callback - the PostQueueCreationCallback to call after a queue is created

unregisterPostQueueCreationCallback

public void unregisterPostQueueCreationCallback(PostQueueCreationCallback callback)

Description copied from interface: ActiveMQServer

Unregister a PostQueueCreationCallback.

Specified by:

unregisterPostQueueCreationCallback in interface ActiveMQServer

Parameters:

callback - the PostQueueCreationCallback to unregister

callPostQueueCreationCallbacks

public void callPostQueueCreationCallbacks(SimpleString queueName)
                                    throws Exception

Specified by:

callPostQueueCreationCallbacks in interface ActiveMQServer

Throws:

Exception

registerPostQueueDeletionCallback

public void registerPostQueueDeletionCallback(PostQueueDeletionCallback callback)

Description copied from interface: ActiveMQServer

Register a PostQueueDeletionCallback to be called after a queue is deleted.

Specified by:

registerPostQueueDeletionCallback in interface ActiveMQServer

Parameters:

callback - the PostQueueDeletionCallback to call after a queue is deleted

unregisterPostQueueDeletionCallback

public void unregisterPostQueueDeletionCallback(PostQueueDeletionCallback callback)

Description copied from interface: ActiveMQServer

Unregister a PostQueueDeletionCallback.

Specified by:

unregisterPostQueueDeletionCallback in interface ActiveMQServer

Parameters:

callback - the PostQueueDeletionCallback to unregister

callPostQueueDeletionCallbacks

public void callPostQueueDeletionCallbacks(SimpleString address,
 SimpleString queueName)
                                    throws Exception

Specified by:

callPostQueueDeletionCallbacks in interface ActiveMQServer

Throws:

Exception

registerBrokerPlugins

public void registerBrokerPlugins(List<ActiveMQServerBasePlugin> plugins)

Specified by:

registerBrokerPlugins in interface ActiveMQServer

registerBrokerPlugin

public void registerBrokerPlugin(ActiveMQServerBasePlugin plugin)

Specified by:

registerBrokerPlugin in interface ActiveMQServer

unRegisterBrokerPlugin

public void unRegisterBrokerPlugin(ActiveMQServerBasePlugin plugin)

Specified by:

unRegisterBrokerPlugin in interface ActiveMQServer

getBrokerPlugins

public List<ActiveMQServerBasePlugin> getBrokerPlugins()

Specified by:

getBrokerPlugins in interface ActiveMQServer

getBrokerConnectionPlugins

public List<ActiveMQServerConnectionPlugin> getBrokerConnectionPlugins()

Specified by:

getBrokerConnectionPlugins in interface ActiveMQServer

getBrokerSessionPlugins

public List<ActiveMQServerSessionPlugin> getBrokerSessionPlugins()

Specified by:

getBrokerSessionPlugins in interface ActiveMQServer

getBrokerConsumerPlugins

public List<ActiveMQServerConsumerPlugin> getBrokerConsumerPlugins()

Specified by:

getBrokerConsumerPlugins in interface ActiveMQServer

getBrokerAddressPlugins

public List<ActiveMQServerAddressPlugin> getBrokerAddressPlugins()

Specified by:

getBrokerAddressPlugins in interface ActiveMQServer

getBrokerQueuePlugins

public List<ActiveMQServerQueuePlugin> getBrokerQueuePlugins()

Specified by:

getBrokerQueuePlugins in interface ActiveMQServer

getBrokerBindingPlugins

public List<ActiveMQServerBindingPlugin> getBrokerBindingPlugins()

Specified by:

getBrokerBindingPlugins in interface ActiveMQServer

getBrokerMessagePlugins

public List<ActiveMQServerMessagePlugin> getBrokerMessagePlugins()

Specified by:

getBrokerMessagePlugins in interface ActiveMQServer

getBrokerBridgePlugins

public List<ActiveMQServerBridgePlugin> getBrokerBridgePlugins()

Specified by:

getBrokerBridgePlugins in interface ActiveMQServer

getBrokerCriticalPlugins

public List<ActiveMQServerCriticalPlugin> getBrokerCriticalPlugins()

Specified by:

getBrokerCriticalPlugins in interface ActiveMQServer

getBrokerFederationPlugins

public List<ActiveMQServerFederationPlugin> getBrokerFederationPlugins()

Specified by:

getBrokerFederationPlugins in interface ActiveMQServer

getBrokerAMQPFederationPlugins

public List<AMQPFederationBrokerPlugin> getBrokerAMQPFederationPlugins()

Specified by:

getBrokerAMQPFederationPlugins in interface ActiveMQServer

getBrokerResourcePlugins

public List<ActiveMQServerResourcePlugin> getBrokerResourcePlugins()

Specified by:

getBrokerResourcePlugins in interface ActiveMQServer

callBrokerPlugins

public void callBrokerPlugins(ActiveMQPluginRunnable pluginRun)
                       throws ActiveMQException

Specified by:

callBrokerPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerConnectionPlugins

public void callBrokerConnectionPlugins(ActiveMQPluginRunnable<ActiveMQServerConnectionPlugin> pluginRun)
                                 throws ActiveMQException

Specified by:

callBrokerConnectionPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerSessionPlugins

public void callBrokerSessionPlugins(ActiveMQPluginRunnable<ActiveMQServerSessionPlugin> pluginRun)
                              throws ActiveMQException

Specified by:

callBrokerSessionPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerConsumerPlugins

public void callBrokerConsumerPlugins(ActiveMQPluginRunnable<ActiveMQServerConsumerPlugin> pluginRun)
                               throws ActiveMQException

Specified by:

callBrokerConsumerPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerAddressPlugins

public void callBrokerAddressPlugins(ActiveMQPluginRunnable<ActiveMQServerAddressPlugin> pluginRun)
                              throws ActiveMQException

Specified by:

callBrokerAddressPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerQueuePlugins

public void callBrokerQueuePlugins(ActiveMQPluginRunnable<ActiveMQServerQueuePlugin> pluginRun)
                            throws ActiveMQException

Specified by:

callBrokerQueuePlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerBindingPlugins

public void callBrokerBindingPlugins(ActiveMQPluginRunnable<ActiveMQServerBindingPlugin> pluginRun)
                              throws ActiveMQException

Specified by:

callBrokerBindingPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerMessagePlugins

public void callBrokerMessagePlugins(ActiveMQPluginRunnable<ActiveMQServerMessagePlugin> pluginRun)
                              throws ActiveMQException

Specified by:

callBrokerMessagePlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerMessagePluginsCanAccept

public boolean callBrokerMessagePluginsCanAccept(ServerConsumer serverConsumer,
 MessageReference messageReference)
                                          throws ActiveMQException

Specified by:

callBrokerMessagePluginsCanAccept in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerBridgePlugins

public void callBrokerBridgePlugins(ActiveMQPluginRunnable<ActiveMQServerBridgePlugin> pluginRun)
                             throws ActiveMQException

Specified by:

callBrokerBridgePlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerCriticalPlugins

public void callBrokerCriticalPlugins(ActiveMQPluginRunnable<ActiveMQServerCriticalPlugin> pluginRun)
                               throws ActiveMQException

Specified by:

callBrokerCriticalPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerFederationPlugins

public void callBrokerFederationPlugins(ActiveMQPluginRunnable<ActiveMQServerFederationPlugin> pluginRun)
                                 throws ActiveMQException

Specified by:

callBrokerFederationPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerAMQPFederationPlugins

public void callBrokerAMQPFederationPlugins(ActiveMQPluginRunnable<AMQPFederationBrokerPlugin> pluginRun)
                                     throws ActiveMQException

Specified by:

callBrokerAMQPFederationPlugins in interface ActiveMQServer

Throws:

ActiveMQException

callBrokerResourcePlugins

public void callBrokerResourcePlugins(ActiveMQPluginRunnable<ActiveMQServerResourcePlugin> pluginRun)
                               throws ActiveMQException

Specified by:

callBrokerResourcePlugins in interface ActiveMQServer

Throws:

ActiveMQException

hasBrokerPlugins

public boolean hasBrokerPlugins()

Specified by:

hasBrokerPlugins in interface ActiveMQServer

hasBrokerConnectionPlugins

public boolean hasBrokerConnectionPlugins()

Specified by:

hasBrokerConnectionPlugins in interface ActiveMQServer

hasBrokerSessionPlugins

public boolean hasBrokerSessionPlugins()

Specified by:

hasBrokerSessionPlugins in interface ActiveMQServer

hasBrokerConsumerPlugins

public boolean hasBrokerConsumerPlugins()

Specified by:

hasBrokerConsumerPlugins in interface ActiveMQServer

hasBrokerAddressPlugins

public boolean hasBrokerAddressPlugins()

Specified by:

hasBrokerAddressPlugins in interface ActiveMQServer

hasBrokerQueuePlugins

public boolean hasBrokerQueuePlugins()

Specified by:

hasBrokerQueuePlugins in interface ActiveMQServer

hasBrokerBindingPlugins

public boolean hasBrokerBindingPlugins()

Specified by:

hasBrokerBindingPlugins in interface ActiveMQServer

hasBrokerMessagePlugins

public boolean hasBrokerMessagePlugins()

Specified by:

hasBrokerMessagePlugins in interface ActiveMQServer

hasBrokerBridgePlugins

public boolean hasBrokerBridgePlugins()

Specified by:

hasBrokerBridgePlugins in interface ActiveMQServer

hasBrokerCriticalPlugins

public boolean hasBrokerCriticalPlugins()

Specified by:

hasBrokerCriticalPlugins in interface ActiveMQServer

hasBrokerFederationPlugins

public boolean hasBrokerFederationPlugins()

Specified by:

hasBrokerFederationPlugins in interface ActiveMQServer

hasBrokerAMQPFederationPlugins

public boolean hasBrokerAMQPFederationPlugins()

Specified by:

hasBrokerAMQPFederationPlugins in interface ActiveMQServer

hasBrokerResourcePlugins

public boolean hasBrokerResourcePlugins()

Specified by:

hasBrokerResourcePlugins in interface ActiveMQServer

getExecutorFactory

public ExecutorFactory getExecutorFactory()

Specified by:

getExecutorFactory in interface ActiveMQServer

getIOExecutorFactory

public ExecutorFactory getIOExecutorFactory()

Specified by:

getIOExecutorFactory in interface ActiveMQServer

setGroupingHandler

public void setGroupingHandler(GroupingHandler groupingHandler)

Specified by:

setGroupingHandler in interface ActiveMQServer

getGroupingHandler

public GroupingHandler getGroupingHandler()

Specified by:

getGroupingHandler in interface ActiveMQServer

getReplicationManager

public ReplicationManager getReplicationManager()

Specified by:

getReplicationManager in interface ActiveMQServer

getConnectorsService

public ConnectorsService getConnectorsService()

Specified by:

getConnectorsService in interface ActiveMQServer

getFederationManager

public FederationManager getFederationManager()

Specified by:

getFederationManager in interface ActiveMQServer

deployDivert

public Divert deployDivert(DivertConfiguration config)
                    throws Exception

Specified by:

deployDivert in interface ActiveMQServer

Throws:

Exception

updateDivert

public Divert updateDivert(DivertConfiguration config)
                    throws Exception

Specified by:

updateDivert in interface ActiveMQServer

Throws:

Exception

destroyDivert

public void destroyDivert(SimpleString name)
                   throws Exception

Specified by:

destroyDivert in interface ActiveMQServer

Throws:

Exception

destroyDivert

public void destroyDivert(SimpleString name,
 boolean deleteFromStorage)
                   throws Exception

Specified by:

destroyDivert in interface ActiveMQServer

Throws:

Exception

deployBridge

public boolean deployBridge(BridgeConfiguration config)
                     throws Exception

Specified by:

deployBridge in interface ActiveMQServer

Throws:

Exception

destroyBridge

public void destroyBridge(String name)
                   throws Exception

Specified by:

destroyBridge in interface ActiveMQServer

Throws:

Exception

deployFederation

public void deployFederation(FederationConfiguration config)
                      throws Exception

Specified by:

deployFederation in interface ActiveMQServer

Throws:

Exception

undeployFederation

public void undeployFederation(String name)
                        throws Exception

Specified by:

undeployFederation in interface ActiveMQServer

Throws:

Exception

getSessionByID

public ServerSession getSessionByID(String sessionName)

Specified by:

getSessionByID in interface ActiveMQServer

toString

public String toString()

Overrides:

toString in class Object

replaceQueueFactory

public void replaceQueueFactory(QueueFactory factory)

For tests only, don't use this method as it's not part of the API

createPagingManager

public PagingManager createPagingManager()
                                  throws Exception

Specified by:

createPagingManager in interface ActiveMQServer

Throws:

Exception

getPagingStoreFactory

protected PagingStoreFactory getPagingStoreFactory()
                                            throws Exception

Throws:

Exception

createStorageManager

protected StorageManager createStorageManager()

This method is protected as it may be used as a hook for creating a custom storage manager (on tests for instance)

getServiceRegistry

public ServiceRegistry getServiceRegistry()

Specified by:

getServiceRegistry in interface ActiveMQServer

installMirrorController

public void installMirrorController(MirrorController mirrorController)

Specified by:

installMirrorController in interface ActiveMQServer

scanAddresses

public void scanAddresses(MirrorController mirrorController)
                   throws Exception

Description copied from interface: ActiveMQServer

This method will scan all queues and addresses. it is supposed to be called before the mirrorController is started

Specified by:

scanAddresses in interface ActiveMQServer

Throws:

Exception

getMirrorController

public MirrorController getMirrorController()

Specified by:

getMirrorController in interface ActiveMQServer

removeMirrorControl

public void removeMirrorControl()

Specified by:

removeMirrorControl in interface ActiveMQServer

injectMonitor

public void injectMonitor(FileStoreMonitor storeMonitor)
                   throws Exception

This method exists for a possibility of test cases replacing the FileStoreMonitor for an extension that would for instance pretend a disk full on certain tests.

Throws:

Exception

getMonitor

public FileStoreMonitor getMonitor()

completeActivation

public void completeActivation(boolean replicated)
                        throws Exception

Throws:

Exception

getDiskStoreUsage

public double getDiskStoreUsage()

Specified by:

getDiskStoreUsage in interface ActiveMQServer

updateAddressInfo

public boolean updateAddressInfo(SimpleString address,
 EnumSet<RoutingType> routingTypes)
                          throws Exception

Description copied from interface: ActiveMQServer

Updates an AddressInfo on the broker with the specified routing types.

Specified by:

updateAddressInfo in interface ActiveMQServer

Parameters:

address - the name of the AddressInfo to update

routingTypes - the routing types to update the AddressInfo with

Returns:

true if the AddressInfo was updated, false otherwise

Throws:

Exception

updateAddressInfo

public boolean updateAddressInfo(SimpleString address,
 Collection<RoutingType> routingTypes)
                          throws Exception

Specified by:

updateAddressInfo in interface ActiveMQServer

Throws:

Exception

addAddressInfo

public boolean addAddressInfo(AddressInfo addressInfo)
                       throws Exception

Description copied from interface: ActiveMQServer

Add the AddressInfo to the broker

Specified by:

addAddressInfo in interface ActiveMQServer

Parameters:

addressInfo - the AddressInfo to add

Returns:

true if the AddressInfo was added, false otherwise

Throws:

Exception

addOrUpdateAddressInfo

public AddressInfo addOrUpdateAddressInfo(AddressInfo addressInfo)
                                   throws Exception

Description copied from interface: ActiveMQServer

A convenience method to combine the functionality of addAddressInfo and updateAddressInfo. It will add the AddressInfo object to the broker if it doesn't exist or update it if it does.

Specified by:

addOrUpdateAddressInfo in interface ActiveMQServer

Parameters:

addressInfo - the AddressInfo to add or the info used to update the existing AddressInfo

Returns:

the resulting AddressInfo

Throws:

Exception

removeAddressInfo

public void removeAddressInfo(SimpleString address,
 SecurityAuth auth)
                       throws Exception

Description copied from interface: ActiveMQServer

Remove an AddressInfo from the broker.

Specified by:

removeAddressInfo in interface ActiveMQServer

Parameters:

address - the AddressInfo to remove

auth - authorization information; null is valid

Throws:

Exception

autoRemoveAddressInfo

public void autoRemoveAddressInfo(SimpleString address,
 SecurityAuth auth)
                           throws Exception

Description copied from interface: ActiveMQServer

Remove an AddressInfo from the broker.

Specified by:

autoRemoveAddressInfo in interface ActiveMQServer

Parameters:

address - the AddressInfo to remove

auth - authorization information; null is valid

Throws:

Exception

registerQueueOnManagement

public void registerQueueOnManagement(Queue queue)
                               throws Exception

Register a queue on the management registry

Specified by:

registerQueueOnManagement in interface ActiveMQServer

Throws:

Exception

removeAddressInfo

public void removeAddressInfo(SimpleString address,
 SecurityAuth auth,
 boolean force)
                       throws Exception

Description copied from interface: ActiveMQServer

Remove an AddressInfo from the broker.

Specified by:

removeAddressInfo in interface ActiveMQServer

Parameters:

address - the AddressInfo to remove

auth - authorization information; null is valid

force - It will disconnect everything from the address including queues and consumers

Throws:

Exception

getInternalNamingPrefix

public String getInternalNamingPrefix()

Specified by:

getInternalNamingPrefix in interface ActiveMQServer

getAddressInfo

public AddressInfo getAddressInfo(SimpleString address)

Specified by:

getAddressInfo in interface ActiveMQServer

createQueue

@Deprecated
public Queue createQueue(AddressInfo addrInfo,
 SimpleString queueName,
 SimpleString filterString,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean ignoreIfExists,
 boolean transientQueue,
 boolean autoCreated,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 SimpleString groupFirstKey,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount,
 boolean autoCreateAddress,
 boolean configurationManaged,
 long ringSize)
                  throws Exception

Deprecated.

Throws:

Exception

createQueue

public Queue createQueue(QueueConfiguration queueConfiguration)
                  throws Exception

Description copied from interface: ActiveMQServer

Overloaded version of ActiveMQServer.createQueue(QueueConfiguration, boolean) where the boolean parameter is always false (i.e. if the queue already exists then an exception will be thrown).

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

See Also:

• ActiveMQServer.createQueue(QueueConfiguration, boolean)

createQueue

public Queue createQueue(QueueConfiguration queueConfiguration,
 boolean ignoreIfExists)
                  throws Exception

Description copied from interface: ActiveMQServer

This method creates a queue based on the QueueConfiguration input. See QueueConfiguration for more details on configuration specifics.

Some dynamic defaults will be enforced via address-settings for the corresponding unset properties:

• maxConsumers
• exclusive
• groupRebalance
• groupBuckets
• groupFirstKey
• lastValue
• lastValueKey
• nonDestructive
• consumersBeforeDispatch
• delayBeforeDispatch
• ringSize
• routingType
• purgeOnNoConsumers
• autoCreateAddress
• autoDelete (only set if queue was auto-created)
• autoDeleteDelay
• autoDeleteMessageCount

Specified by:

createQueue in interface ActiveMQServer

Parameters:

queueConfiguration - the configuration to use when creating the queue

ignoreIfExists - whether to simply return without an exception if the queue exists

Returns:

the Queue instance that was created

Throws:

Exception

getRuntimeTempQueueNamespace

public String getRuntimeTempQueueNamespace(boolean temporary)

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filterString,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean ignoreIfExists,
 boolean transientQueue,
 boolean autoCreated,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filterString,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean ignoreIfExists,
 boolean transientQueue,
 boolean autoCreated,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 SimpleString groupFirstKey,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount,
 boolean autoCreateAddress)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

@Deprecated
public Queue createQueue(SimpleString address,
 RoutingType routingType,
 SimpleString queueName,
 SimpleString filterString,
 SimpleString user,
 boolean durable,
 boolean temporary,
 boolean ignoreIfExists,
 boolean transientQueue,
 boolean autoCreated,
 int maxConsumers,
 boolean purgeOnNoConsumers,
 boolean exclusive,
 boolean groupRebalance,
 int groupBuckets,
 SimpleString groupFirstKey,
 boolean lastValue,
 SimpleString lastValueKey,
 boolean nonDestructive,
 int consumersBeforeDispatch,
 long delayBeforeDispatch,
 boolean autoDelete,
 long autoDeleteDelay,
 long autoDeleteMessageCount,
 boolean autoCreateAddress,
 long ringSize)
                  throws Exception

Deprecated.

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

updateQueue

@Deprecated
public Queue updateQueue(String name,
 RoutingType routingType,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers)
                  throws Exception

Deprecated.

Specified by:

updateQueue in interface ActiveMQServer

Throws:

Exception

updateQueue

@Deprecated
public Queue updateQueue(String name,
 RoutingType routingType,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive)
                  throws Exception

Deprecated.

Specified by:

updateQueue in interface ActiveMQServer

Throws:

Exception

updateQueue

@Deprecated
public Queue updateQueue(String name,
 RoutingType routingType,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive,
 String user)
                  throws Exception

Deprecated.

Specified by:

updateQueue in interface ActiveMQServer

Throws:

Exception

updateQueue

@Deprecated
public Queue updateQueue(String name,
 RoutingType routingType,
 String filterString,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive,
 Boolean groupRebalance,
 Integer groupBuckets,
 Boolean nonDestructive,
 Integer consumersBeforeDispatch,
 Long delayBeforeDispatch,
 String user)
                  throws Exception

Deprecated.

Specified by:

updateQueue in interface ActiveMQServer

Throws:

Exception

updateQueue

@Deprecated
public Queue updateQueue(String name,
 RoutingType routingType,
 String filterString,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive,
 Boolean groupRebalance,
 Integer groupBuckets,
 String groupFirstKey,
 Boolean nonDestructive,
 Integer consumersBeforeDispatch,
 Long delayBeforeDispatch,
 String user)
                  throws Exception

Deprecated.

Specified by:

updateQueue in interface ActiveMQServer

Throws:

Exception

updateQueue

@Deprecated
public Queue updateQueue(String name,
 RoutingType routingType,
 String filterString,
 Integer maxConsumers,
 Boolean purgeOnNoConsumers,
 Boolean exclusive,
 Boolean groupRebalance,
 Integer groupBuckets,
 String groupFirstKey,
 Boolean nonDestructive,
 Integer consumersBeforeDispatch,
 Long delayBeforeDispatch,
 String user,
 Long ringSize)
                  throws Exception

Deprecated.

Specified by:

updateQueue in interface ActiveMQServer

Throws:

Exception

updateQueue

public Queue updateQueue(QueueConfiguration queueConfiguration)
                  throws Exception

Description copied from interface: ActiveMQServer

Update the queue named in the QueueConfiguration with the corresponding properties. Set only the properties that you wish to change from their existing values. Only the following properties can actually be updated:

• routingType
• filter
• maxConsumers
• purgeOnNoConsumers
• exclusive
• nonDestructive
• groupRebalance
• groupFirstKey
• groupBuckets
• consumersBeforeDispatch
• delayBeforeDispatch
• configurationManaged
• user
• ringSize

The other configuration attributes are immutable and will be ignored if set.

Specified by:

updateQueue in interface ActiveMQServer

Parameters:

queueConfiguration - the QueueConfiguration to use

Returns:

the updated Queue instance

Throws:

Exception

updateQueue

public Queue updateQueue(QueueConfiguration queueConfiguration,
 boolean forceUpdate)
                  throws Exception

Description copied from interface: ActiveMQServer

Update a queue's configuration.

Specified by:

updateQueue in interface ActiveMQServer

Parameters:

queueConfiguration - the QueueConfiguration to use

forceUpdate - If true, no null check is performed and unset queueConfiguration values are reset to null

Returns:

the updated Queue instance

Throws:

Exception

See Also:

• ActiveMQServer.updateQueue(QueueConfiguration)

checkJournalDirectory

public void checkJournalDirectory()

Check if journal directory exists or create it (if configured to do so)

addProtocolManagerFactory

public void addProtocolManagerFactory(ProtocolManagerFactory factory)

Description copied from interface: ActiveMQServer

add a ProtocolManagerFactory to be used. Note if Configuration.isResolveProtocols() is true then this factory will replace any factories with the same protocol

Specified by:

addProtocolManagerFactory in interface ActiveMQServer

removeProtocolManagerFactory

public void removeProtocolManagerFactory(ProtocolManagerFactory factory)

Specified by:

removeProtocolManagerFactory in interface ActiveMQServer

createBackupServer

public ActiveMQServer createBackupServer(Configuration configuration)

Specified by:

createBackupServer in interface ActiveMQServer

addScaledDownNode

public void addScaledDownNode(SimpleString scaledDownNodeId)

Specified by:

addScaledDownNode in interface ActiveMQServer

hasScaledDown

public boolean hasScaledDown(SimpleString scaledDownNodeId)

Specified by:

hasScaledDown in interface ActiveMQServer

getUptime

public String getUptime()

Specified by:

getUptime in interface ActiveMQServer

getUptimeMillis

public long getUptimeMillis()

Specified by:

getUptimeMillis in interface ActiveMQServer

addClientConnection

public boolean addClientConnection(String clientId,
 boolean unique)

Specified by:

addClientConnection in interface ActiveMQServer

removeClientConnection

public void removeClientConnection(String clientId)

Specified by:

removeClientConnection in interface ActiveMQServer

reloadConfigurationFile

public void reloadConfigurationFile()
                             throws Exception

Specified by:

reloadConfigurationFile in interface ActiveMQServer

Throws:

Exception

getActivateCallbacks

public Set<ActivateCallback> getActivateCallbacks()

getExternalComponents

public List<ActiveMQComponent> getExternalComponents()

Specified by:

getExternalComponents in interface ActiveMQServer

managementLock

public AutoCloseable managementLock()
                             throws Exception

Specified by:

managementLock in interface ActiveMQServer

Throws:

Exception

getIoCriticalErrorListener

public IOCriticalErrorListener getIoCriticalErrorListener()

Description copied from interface: ActiveMQServer

The server has a default listener that will propagate errors to registered listeners. This will return the main listener

Specified by:

getIoCriticalErrorListener in interface ActiveMQServer

getMirrorRegistry

public MirrorRegistry getMirrorRegistry()

Specified by:

getMirrorRegistry in interface ActiveMQServer

getPendingMirrorAcks

public int getPendingMirrorAcks()

Specified by:

getPendingMirrorAcks in interface ActiveMQServer