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

Class ActiveMQServerImpl

java.lang.Object

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

All Implemented Interfaces:

org.apache.activemq.artemis.core.server.ActiveMQComponent, ActiveMQServer

public class ActiveMQServerImpl
extends Object
implements ActiveMQServer

The ActiveMQ Artemis server implementation

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ActiveMQServerImpl.ShutdownOnCriticalErrorListener

Field Summary

Fields

Modifier and Type	Field and Description
static String	GENERIC_IGNORED_FILTER Deprecated. Replaced by Filter.GENERIC_IGNORED_FILTER

Constructor Summary

Constructors

Constructor and Description
ActiveMQServerImpl()
ActiveMQServerImpl(Configuration configuration)
ActiveMQServerImpl(Configuration configuration, ActiveMQSecurityManager securityManager)
ActiveMQServerImpl(Configuration configuration, ActiveMQServer parentServer)
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)

Method Summary

Modifier and Type	Method and Description
void	addActivationParam(String key, Object val)
boolean	addClientConnection(String clientId, boolean unique)
void	addExternalComponent(org.apache.activemq.artemis.core.server.ActiveMQComponent externalComponent)
void	addProtocolManagerFactory(ProtocolManagerFactory factory)
void	addScaledDownNode(org.apache.activemq.artemis.api.core.SimpleString scaledDownNodeId)
BindingQueryResult	bindingQuery(org.apache.activemq.artemis.api.core.SimpleString address)
void	callActivationFailureListeners(Exception e) Alert activation failure listeners of a failure.
void	callPostQueueCreationCallbacks(org.apache.activemq.artemis.api.core.SimpleString queueName)
void	callPostQueueDeletionCallbacks(org.apache.activemq.artemis.api.core.SimpleString address, org.apache.activemq.artemis.api.core.SimpleString queueName)
void	checkJournalDirectory() Check if journal directory exists or create it (if configured to do so)
boolean	checkLiveIsNotColocated(String nodeId)
void	checkQueueCreationLimit(String username)
void	completeActivation()
ActiveMQServer	createBackupServer(Configuration configuration)
protected NodeManager	createNodeManager(File directory, boolean replicatingBackup)
protected PagingManager	createPagingManager()
Queue	createQueue(org.apache.activemq.artemis.api.core.SimpleString address, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.SimpleString filterString, boolean durable, boolean temporary)
Queue	createQueue(org.apache.activemq.artemis.api.core.SimpleString address, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.SimpleString filterString, org.apache.activemq.artemis.api.core.SimpleString user, boolean durable, boolean temporary)
Queue	createQueue(org.apache.activemq.artemis.api.core.SimpleString address, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.SimpleString filterString, org.apache.activemq.artemis.api.core.SimpleString user, boolean durable, boolean temporary, boolean autoCreated)
ServerSession	createSession(String name, String username, String password, int minLargeMessageSize, org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, boolean autoCreateQueues, OperationContext context)
void	createSharedQueue(org.apache.activemq.artemis.api.core.SimpleString address, org.apache.activemq.artemis.api.core.SimpleString name, org.apache.activemq.artemis.api.core.SimpleString filterString, org.apache.activemq.artemis.api.core.SimpleString user, boolean durable) Creates a transient queue.
void	deployBridge(BridgeConfiguration config)
void	deployDivert(DivertConfiguration config)
Queue	deployQueue(org.apache.activemq.artemis.api.core.SimpleString address, org.apache.activemq.artemis.api.core.SimpleString resourceName, org.apache.activemq.artemis.api.core.SimpleString filterString, boolean durable, boolean temporary)
Queue	deployQueue(org.apache.activemq.artemis.api.core.SimpleString address, org.apache.activemq.artemis.api.core.SimpleString resourceName, org.apache.activemq.artemis.api.core.SimpleString filterString, boolean durable, boolean temporary, boolean autoCreated)
String	describe()
void	destroyBridge(String name)
String	destroyConnectionWithSessionMetadata(String metaKey, String parameterValue)
void	destroyDivert(org.apache.activemq.artemis.api.core.SimpleString name)
void	destroyQueue(org.apache.activemq.artemis.api.core.SimpleString queueName)
void	destroyQueue(org.apache.activemq.artemis.api.core.SimpleString queueName, SecurityAuth session)
void	destroyQueue(org.apache.activemq.artemis.api.core.SimpleString queueName, SecurityAuth session, boolean checkConsumerCount)
void	destroyQueue(org.apache.activemq.artemis.api.core.SimpleString queueName, SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers)
protected void	finalize()
Activation	getActivation()
ActiveMQServerControlImpl	getActiveMQServerControl() Returns the resource to manage this ActiveMQ Artemis server.
HierarchicalRepository<AddressSettings>	getAddressSettingsRepository()
BackupManager	getBackupManager()
ClusterManager	getClusterManager()
Configuration	getConfiguration()
int	getConnectionCount()
ConnectorsService	getConnectorsService()
org.apache.activemq.artemis.utils.ExecutorFactory	getExecutorFactory()
GroupingHandler	getGroupingHandler()
HAPolicy	getHAPolicy()
String	getIdentity()
org.apache.activemq.artemis.utils.ExecutorFactory	getIOExecutorFactory()
QueueCreator	getJMSDestinationCreator()
QueueDeleter	getJMSQueueDeleter()
ManagementService	getManagementService()
FileStoreMonitor	getMonitor()
org.apache.activemq.artemis.api.core.SimpleString	getNodeID()
NodeManager	getNodeManager()
PagingManager	getPagingManager()
protected PagingStoreFactoryNIO	getPagingStoreFactory()
PostOffice	getPostOffice()
int	getQueueCountForUser(String username)
QueueFactory	getQueueFactory()
ReloadManager	getReloadManager()
RemotingService	getRemotingService()
ReplicationManager	getReplicationManager()
ResourceManager	getResourceManager()
ScheduledExecutorService	getScheduledPool()
ActiveMQSecurityManager	getSecurityManager()
HierarchicalRepository<Set<org.apache.activemq.artemis.core.security.Role>>	getSecurityRepository()
SecurityStore	getSecurityStore()
ServiceRegistry	getServiceRegistry()
ServerSession	getSessionByID(String sessionName)
Set<ServerSession>	getSessions()
List<ServerSession>	getSessions(String connectionID)
org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.SERVER_STATE	getState()
StorageManager	getStorageManager()
ExecutorService	getThreadPool()
long	getTotalConnectionCount()
long	getTotalConsumerCount()
long	getTotalMessageCount()
long	getTotalMessagesAcknowledged()
long	getTotalMessagesAdded()
String	getUptime()
long	getUptimeMillis()
org.apache.activemq.artemis.core.version.Version	getVersion()
boolean	hasScaledDown(org.apache.activemq.artemis.api.core.SimpleString scaledDownNodeId)
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.
protected ServerSessionImpl	internalCreateSession(String name, String username, String password, String validatedUser, int minLargeMessageSize, org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, OperationContext context, boolean autoCreateJMSQueues)
void	interrupBackupThread(NodeManager nodeManagerInUse)
boolean	isActive()
boolean	isAddressBound(String address) return true if there is a binding for this address (i.e.
boolean	isReplicaSync() Returns whether the initial replication synchronization process with the backup server is complete; applicable for either the live or backup server.
boolean	isStarted()
Queue	locateQueue(org.apache.activemq.artemis.api.core.SimpleString queueName)
void	lockActivation() it will hold a lock for the activation.
ServerSession	lookupSession(String key, String value)
OperationContext	newOperationContext()
org.apache.activemq.artemis.core.server.QueueQueryResult	queueQuery(org.apache.activemq.artemis.api.core.SimpleString name)
void	registerActivateCallback(ActivateCallback callback)
void	registerActivationFailureListener(ActivationFailureListener listener) Register a listener to detect problems during activation
void	registerPostQueueCreationCallback(PostQueueCreationCallback callback)
void	registerPostQueueDeletionCallback(PostQueueDeletionCallback callback)
void	removeClientConnection(String clientId)
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	resetNodeManager()
void	setActivation(SharedNothingLiveActivation activation)
void	setGroupingHandler(GroupingHandler groupingHandler)
void	setHAPolicy(HAPolicy haPolicy)
void	setIdentity(String identity) Sets the server identity.
void	setJMSQueueCreator(QueueCreator jmsQueueCreator) This is the queue creator responsible for automatic JMS Queue creations.
void	setJMSQueueDeleter(QueueDeleter jmsQueueDeleter) This is the queue deleter responsible for automatic JMS Queue deletions.
void	setMBeanServer(MBeanServer mbeanServer)
void	setState(org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.SERVER_STATE state)
void	start()
void	stop()
void	stop(boolean failoverOnServerShutdown)
void	stopTheServer(boolean criticalIOError) Stops the server in a different thread.
void	threadDump()
String	toString()
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	unregisterPostQueueCreationCallback(PostQueueCreationCallback callback)
void	unregisterPostQueueDeletionCallback(PostQueueDeletionCallback callback)
boolean	waitForActivation(long timeout, TimeUnit unit) Wait for server initialization.

Methods inherited from class java.lang.Object

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

Field Detail

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

Constructor Detail

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 Detail

getReloadManager

public ReloadManager getReloadManager()

Specified by:

getReloadManager in interface ActiveMQServer

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 org.apache.activemq.artemis.core.server.ActiveMQComponent

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

finalize

protected final void finalize()
                       throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

setState

public void setState(org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.SERVER_STATE state)

getState

public org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.SERVER_STATE getState()

interrupBackupThread

public void interrupBackupThread(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

addExternalComponent

public void addExternalComponent(org.apache.activemq.artemis.core.server.ActiveMQComponent externalComponent)

Specified by:

addExternalComponent in interface ActiveMQServer

getThreadPool

public ExecutorService getThreadPool()

setActivation

public void setActivation(SharedNothingLiveActivation activation)

stopTheServer

public final void stopTheServer(boolean criticalIOError)

Stops the server in a different thread.

stop

public final void stop()
                throws Exception

Specified by:

stop in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

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

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

Specified by:

isAddressBound in interface ActiveMQServer

Returns:

Throws:

Exception

bindingQuery

public BindingQueryResult bindingQuery(org.apache.activemq.artemis.api.core.SimpleString address)
                                throws Exception

Specified by:

bindingQuery in interface ActiveMQServer

Throws:

Exception

queueQuery

public org.apache.activemq.artemis.core.server.QueueQueryResult queueQuery(org.apache.activemq.artemis.api.core.SimpleString name)

Specified by:

queueQuery in interface ActiveMQServer

threadDump

public void threadDump()

Specified by:

threadDump in interface ActiveMQServer

stop

public final void stop(boolean failoverOnServerShutdown)
                throws Exception

Specified by:

stop in interface ActiveMQServer

Throws:

Exception

getJMSDestinationCreator

public QueueCreator getJMSDestinationCreator()

Specified by:

getJMSDestinationCreator in interface ActiveMQServer

See Also:

ActiveMQServer.setJMSQueueCreator(QueueCreator)

setJMSQueueCreator

public void setJMSQueueCreator(QueueCreator jmsQueueCreator)

Description copied from interface: ActiveMQServer

This is the queue creator responsible for automatic JMS Queue creations.

Specified by:

setJMSQueueCreator in interface ActiveMQServer

getJMSQueueDeleter

public QueueDeleter getJMSQueueDeleter()

Specified by:

getJMSQueueDeleter in interface ActiveMQServer

See Also:

ActiveMQServer.setJMSQueueDeleter(QueueDeleter)

setJMSQueueDeleter

public void setJMSQueueDeleter(QueueDeleter jmsQueueDeleter)

Description copied from interface: ActiveMQServer

This is the queue deleter responsible for automatic JMS Queue deletions.

Specified by:

setJMSQueueDeleter in interface ActiveMQServer

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 live or backup server.

Specified by:

isReplicaSync in interface ActiveMQServer

checkLiveIsNotColocated

public boolean checkLiveIsNotColocated(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<org.apache.activemq.artemis.core.security.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

getVersion

public org.apache.activemq.artemis.core.version.Version getVersion()

Specified by:

getVersion in interface ActiveMQServer

isStarted

public boolean isStarted()

Specified by:

isStarted in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

getClusterManager

public ClusterManager getClusterManager()

Specified by:

getClusterManager in interface ActiveMQServer

getBackupManager

public BackupManager getBackupManager()

createSession

public ServerSession createSession(String name,
                                   String username,
                                   String password,
                                   int minLargeMessageSize,
                                   org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection,
                                   boolean autoCommitSends,
                                   boolean autoCommitAcks,
                                   boolean preAcknowledge,
                                   boolean xa,
                                   String defaultAddress,
                                   SessionCallback callback,
                                   boolean autoCreateQueues,
                                   OperationContext context)
                            throws Exception

Specified by:

createSession 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,
                                                  org.apache.activemq.artemis.spi.core.protocol.RemotingConnection connection,
                                                  boolean autoCommitSends,
                                                  boolean autoCommitAcks,
                                                  boolean preAcknowledge,
                                                  boolean xa,
                                                  String defaultAddress,
                                                  SessionCallback callback,
                                                  OperationContext context,
                                                  boolean autoCreateJMSQueues)
                                           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)

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

getConnectionCount

public int getConnectionCount()

Specified by:

getConnectionCount in interface ActiveMQServer

getTotalConnectionCount

public long getTotalConnectionCount()

Specified by:

getTotalConnectionCount 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 org.apache.activemq.artemis.api.core.SimpleString getNodeID()

Specified by:

getNodeID in interface ActiveMQServer

createQueue

public Queue createQueue(org.apache.activemq.artemis.api.core.SimpleString address,
                         org.apache.activemq.artemis.api.core.SimpleString queueName,
                         org.apache.activemq.artemis.api.core.SimpleString filterString,
                         boolean durable,
                         boolean temporary)
                  throws Exception

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

public Queue createQueue(org.apache.activemq.artemis.api.core.SimpleString address,
                         org.apache.activemq.artemis.api.core.SimpleString queueName,
                         org.apache.activemq.artemis.api.core.SimpleString filterString,
                         org.apache.activemq.artemis.api.core.SimpleString user,
                         boolean durable,
                         boolean temporary)
                  throws Exception

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createQueue

public Queue createQueue(org.apache.activemq.artemis.api.core.SimpleString address,
                         org.apache.activemq.artemis.api.core.SimpleString queueName,
                         org.apache.activemq.artemis.api.core.SimpleString filterString,
                         org.apache.activemq.artemis.api.core.SimpleString user,
                         boolean durable,
                         boolean temporary,
                         boolean autoCreated)
                  throws Exception

Specified by:

createQueue in interface ActiveMQServer

Throws:

Exception

createSharedQueue

public void createSharedQueue(org.apache.activemq.artemis.api.core.SimpleString address,
                              org.apache.activemq.artemis.api.core.SimpleString name,
                              org.apache.activemq.artemis.api.core.SimpleString filterString,
                              org.apache.activemq.artemis.api.core.SimpleString user,
                              boolean durable)
                       throws Exception

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:

org.apache.activemq.artemis.api.core.ActiveMQInvalidTransientQueueUseException - if the shared queue already exists with a different address or filterString

NullPointerException - if address is null

Exception

locateQueue

public Queue locateQueue(org.apache.activemq.artemis.api.core.SimpleString queueName)

Specified by:

locateQueue in interface ActiveMQServer

deployQueue

public Queue deployQueue(org.apache.activemq.artemis.api.core.SimpleString address,
                         org.apache.activemq.artemis.api.core.SimpleString resourceName,
                         org.apache.activemq.artemis.api.core.SimpleString filterString,
                         boolean durable,
                         boolean temporary)
                  throws Exception

Specified by:

deployQueue in interface ActiveMQServer

Throws:

Exception

deployQueue

public Queue deployQueue(org.apache.activemq.artemis.api.core.SimpleString address,
                         org.apache.activemq.artemis.api.core.SimpleString resourceName,
                         org.apache.activemq.artemis.api.core.SimpleString filterString,
                         boolean durable,
                         boolean temporary,
                         boolean autoCreated)
                  throws Exception

Specified by:

deployQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(org.apache.activemq.artemis.api.core.SimpleString queueName)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(org.apache.activemq.artemis.api.core.SimpleString queueName,
                         SecurityAuth session)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(org.apache.activemq.artemis.api.core.SimpleString queueName,
                         SecurityAuth session,
                         boolean checkConsumerCount)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

destroyQueue

public void destroyQueue(org.apache.activemq.artemis.api.core.SimpleString queueName,
                         SecurityAuth session,
                         boolean checkConsumerCount,
                         boolean removeConsumers)
                  throws Exception

Specified by:

destroyQueue in interface ActiveMQServer

Throws:

Exception

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

Parameters:

listener - @see org.apache.activemq.artemis.core.server.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

registerPostQueueCreationCallback

public void registerPostQueueCreationCallback(PostQueueCreationCallback callback)

Specified by:

registerPostQueueCreationCallback in interface ActiveMQServer

Parameters:

callback - PostQueueCreationCallback

unregisterPostQueueCreationCallback

public void unregisterPostQueueCreationCallback(PostQueueCreationCallback callback)

Specified by:

unregisterPostQueueCreationCallback in interface ActiveMQServer

Parameters:

callback - PostQueueCreationCallback

callPostQueueCreationCallbacks

public void callPostQueueCreationCallbacks(org.apache.activemq.artemis.api.core.SimpleString queueName)
                                    throws Exception

Specified by:

callPostQueueCreationCallbacks in interface ActiveMQServer

Throws:

Exception

registerPostQueueDeletionCallback

public void registerPostQueueDeletionCallback(PostQueueDeletionCallback callback)

Specified by:

registerPostQueueDeletionCallback in interface ActiveMQServer

Parameters:

callback - PostQueueDeletionCallback

unregisterPostQueueDeletionCallback

public void unregisterPostQueueDeletionCallback(PostQueueDeletionCallback callback)

Specified by:

unregisterPostQueueDeletionCallback in interface ActiveMQServer

Parameters:

callback - PostQueueDeletionCallback

callPostQueueDeletionCallbacks

public void callPostQueueDeletionCallbacks(org.apache.activemq.artemis.api.core.SimpleString address,
                                           org.apache.activemq.artemis.api.core.SimpleString queueName)
                                    throws Exception

Specified by:

callPostQueueDeletionCallbacks in interface ActiveMQServer

Throws:

Exception

getExecutorFactory

public org.apache.activemq.artemis.utils.ExecutorFactory getExecutorFactory()

Specified by:

getExecutorFactory in interface ActiveMQServer

getIOExecutorFactory

public org.apache.activemq.artemis.utils.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

deployDivert

public void deployDivert(DivertConfiguration config)
                  throws Exception

Specified by:

deployDivert in interface ActiveMQServer

Throws:

Exception

destroyDivert

public void destroyDivert(org.apache.activemq.artemis.api.core.SimpleString name)
                   throws Exception

Specified by:

destroyDivert in interface ActiveMQServer

Throws:

Exception

deployBridge

public void 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

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

Parameters:

factory -

createPagingManager

protected PagingManager createPagingManager()

getPagingStoreFactory

protected PagingStoreFactoryNIO getPagingStoreFactory()

getServiceRegistry

public ServiceRegistry getServiceRegistry()

Specified by:

getServiceRegistry 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()
                        throws Exception

Throws:

Exception

checkJournalDirectory

public void checkJournalDirectory()

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

addProtocolManagerFactory

public void addProtocolManagerFactory(ProtocolManagerFactory factory)

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(org.apache.activemq.artemis.api.core.SimpleString scaledDownNodeId)

Specified by:

addScaledDownNode in interface ActiveMQServer

hasScaledDown

public boolean hasScaledDown(org.apache.activemq.artemis.api.core.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