ActiveMQServerImpl (Red Hat JBoss Enterprise Application Platform 7.2.0.Beta public API)

java.lang.Object
- org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl

All Implemented Interfaces:

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

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

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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addActivationParam(String key, Object val)`
`boolean`	`addClientConnection(String clientId, boolean unique)`
`void`	`addExternalComponent(ActiveMQComponent externalComponent)`
`void`	`addProtocolManagerFactory(ProtocolManagerFactory factory)`
`void`	`addScaledDownNode(SimpleString scaledDownNodeId)`
`BindingQueryResult`	`bindingQuery(SimpleString address)`
`void`	`callActivationFailureListeners(Exception e)` Alert activation failure listeners of a failure.
`void`	`callPostQueueCreationCallbacks(SimpleString queueName)`
`void`	`callPostQueueDeletionCallbacks(SimpleString address, 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(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)`
`Queue`	`createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary)`
`Queue`	`createQueue(SimpleString address, SimpleString queueName, SimpleString filterString, SimpleString user, boolean durable, boolean temporary, boolean autoCreated)`
`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)`
`void`	`createSharedQueue(SimpleString address, SimpleString name, SimpleString filterString, SimpleString user, boolean durable)` Creates a transient queue.
`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)
`void`	`deployBridge(BridgeConfiguration config)`
`void`	`deployDivert(DivertConfiguration config)`
`Queue`	`deployQueue(SimpleString address, SimpleString resourceName, SimpleString filterString, boolean durable, boolean temporary)`
`Queue`	`deployQueue(SimpleString address, SimpleString resourceName, SimpleString filterString, boolean durable, boolean temporary, boolean autoCreated)`
`String`	`describe()`
`void`	`destroyBridge(String name)`
`String`	`destroyConnectionWithSessionMetadata(String metaKey, String parameterValue)`
`void`	`destroyDivert(SimpleString name)`
`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)`
`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()`
`IOCriticalErrorListener`	`getCriticalIOErrorListener()`
`ExecutorFactory`	`getExecutorFactory()`
`GroupingHandler`	`getGroupingHandler()`
`HAPolicy`	`getHAPolicy()`
`String`	`getIdentity()`
`ExecutorFactory`	`getIOExecutorFactory()`
`QueueCreator`	`getJMSDestinationCreator()`
`QueueDeleter`	`getJMSQueueDeleter()`
`ManagementService`	`getManagementService()`
`FileStoreMonitor`	`getMonitor()`
`NetworkHealthCheck`	`getNetworkHealthCheck()`
`SimpleString`	`getNodeID()`
`NodeManager`	`getNodeManager()`
`PagingManager`	`getPagingManager()`
`protected PagingStoreFactory`	`getPagingStoreFactory()`
`PostOffice`	`getPostOffice()`
`int`	`getQueueCountForUser(String username)`
`QueueFactory`	`getQueueFactory()`
`ReloadManager`	`getReloadManager()`
`RemotingService`	`getRemotingService()`
`ReplicationEndpoint`	`getReplicationEndpoint()`
`ReplicationManager`	`getReplicationManager()`
`ResourceManager`	`getResourceManager()`
`ScheduledExecutorService`	`getScheduledPool()`
`ActiveMQSecurityManager`	`getSecurityManager()`
`HierarchicalRepository<Set<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()`
`Version`	`getVersion()`
`boolean`	`hasScaledDown(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, RemotingConnection connection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, OperationContext context, boolean autoCreateJMSQueues)`
`void`	`interruptActivationThread(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(SimpleString queueName)`
`void`	`lockActivation()` it will hold a lock for the activation.
`ServerSession`	`lookupSession(String key, String value)`
`OperationContext`	`newOperationContext()`
`QueueQueryResult`	`queueQuery(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

getNetworkHealthCheck
```
public NetworkHealthCheck getNetworkHealthCheck()
```
Specified by:

getNetworkHealthCheck 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 ActiveMQComponent

Throws:

Exception

getReplicationEndpoint
```
public ReplicationEndpoint getReplicationEndpoint()
```
Specified by:

getReplicationEndpoint in interface ActiveMQServer

Returns:

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()

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

addExternalComponent
```
public void addExternalComponent(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 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(SimpleString address)
                                throws Exception

Specified by:: bindingQuery in interface ActiveMQServer
Throws:: Exception

queueQuery

public QueueQueryResult queueQuery(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<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 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

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)
                            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,
                                                  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 SimpleString getNodeID()
```
Specified by:

getNodeID in interface ActiveMQServer

createQueue

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

Specified by:: createQueue in interface ActiveMQServer
Throws:: Exception

createQueue

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

Specified by:: createQueue in interface ActiveMQServer
Throws:: Exception

createQueue

public Queue createQueue(SimpleString address,
                         SimpleString queueName,
                         SimpleString filterString,
                         SimpleString user,
                         boolean durable,
                         boolean temporary,
                         boolean autoCreated)
                  throws Exception

Specified by:: createQueue in interface ActiveMQServer
Throws:: Exception

createSharedQueue
```
public void createSharedQueue(SimpleString address,
                              SimpleString name,
                              SimpleString filterString,
                              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:

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

NullPointerException - if address is null

Exception

locateQueue
```
public Queue locateQueue(SimpleString queueName)
```
Specified by:

locateQueue in interface ActiveMQServer

deployQueue

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

Specified by:: deployQueue in interface ActiveMQServer
Throws:: Exception

deployQueue

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

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

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(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(SimpleString address,
                                           SimpleString queueName)
                                    throws Exception

Specified by:: callPostQueueDeletionCallbacks in interface ActiveMQServer
Throws:: Exception

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

deployDivert

public void deployDivert(DivertConfiguration config)
                  throws Exception

Specified by:: deployDivert in interface ActiveMQServer
Throws:: Exception

destroyDivert

public void destroyDivert(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()
                                     throws Exception

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

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

getCriticalIOErrorListener
```
public IOCriticalErrorListener getCriticalIOErrorListener()
```
Specified by:

getCriticalIOErrorListener in interface ActiveMQServer

Class ActiveMQServerImpl

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

GENERIC_IGNORED_FILTER

Constructor Detail

ActiveMQServerImpl

ActiveMQServerImpl

ActiveMQServerImpl

ActiveMQServerImpl

ActiveMQServerImpl

ActiveMQServerImpl

ActiveMQServerImpl

ActiveMQServerImpl

Method Detail

getReloadManager

getNetworkHealthCheck

createNodeManager

newOperationContext

start

getReplicationEndpoint

unlockActivation

lockActivation

finalize

setState

getState

interruptActivationThread

resetNodeManager

getActivation

getHAPolicy

setHAPolicy

setMBeanServer

addExternalComponent

getThreadPool

setActivation

stopTheServer

stop

addActivationParam

isAddressBound

bindingQuery

queueQuery

threadDump

stop

getJMSDestinationCreator

setJMSQueueCreator

getJMSQueueDeleter

setJMSQueueDeleter

isReplicaSync

checkLiveIsNotColocated

describe

destroyConnectionWithSessionMetadata

setIdentity

getIdentity

getScheduledPool

getConfiguration

getPagingManager

getRemotingService

getStorageManager

getSecurityManager

getManagementService

getSecurityRepository

getNodeManager

getAddressSettingsRepository

getResourceManager

getVersion

isStarted

getClusterManager

getBackupManager

createSession

checkQueueCreationLimit

getQueueCountForUser

internalCreateSession

getSecurityStore

removeSession

lookupSession

getSessions

getSessions