org.apache.activemq.artemis.core.server

Interface ActiveMQServer

All Superinterfaces:

ActiveMQComponent

All Known Implementing Classes:

ActiveMQServerImpl

public interface ActiveMQServer
extends ActiveMQComponent

This interface defines the internal interface of the ActiveMQ Artemis Server exposed to other components of the server.

This is not part of our public API.

Method Summary

Modifier and Type	Method and Description
void	addActivationParam(String key, Object val)
void	addProtocolManagerFactory(ProtocolManagerFactory factory)
void	addScaledDownNode(SimpleString scaledDownNodeId)
void	checkQueueCreationLimit(String username)
ActiveMQServer	createBackupServer(Configuration configuration)
Queue	createQueue(SimpleString address, SimpleString queueName, SimpleString filter, boolean durable, boolean temporary)
Queue	createQueue(SimpleString address, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary)
Queue	createQueue(SimpleString address, SimpleString queueName, SimpleString filter, SimpleString user, boolean durable, boolean temporary, boolean autoCreated)
ServerSession	createSession(String name, String username, String password, int minLargeMessageSize, RemotingConnection remotingConnection, boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge, boolean xa, String defaultAddress, SessionCallback callback, ServerSessionFactory sessionFactory, boolean autoCreateQueues)
void	createSharedQueue(SimpleString address, SimpleString name, SimpleString filterString, SimpleString user, boolean durable) Creates a shared queue.
void	deployBridge(BridgeConfiguration config)
void	deployDivert(DivertConfiguration config)
Queue	deployQueue(SimpleString address, SimpleString queueName, SimpleString filterString, boolean durable, boolean temporary)
String	describe()
void	destroyBridge(String name)
String	destroyConnectionWithSessionMetadata(String metaKey, String metaValue)
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)
Activation	getActivation()
ActiveMQServerControlImpl	getActiveMQServerControl() Returns the resource to manage this ActiveMQ Artemis server.
HierarchicalRepository<AddressSettings>	getAddressSettingsRepository()
ClusterManager	getClusterManager()
Configuration	getConfiguration()
int	getConnectionCount()
ConnectorsService	getConnectorsService()
ExecutorFactory	getExecutorFactory()
GroupingHandler	getGroupingHandler()
HAPolicy	getHAPolicy()
String	getIdentity()
QueueCreator	getJMSQueueCreator()
ManagementService	getManagementService()
SimpleString	getNodeID()
NodeManager	getNodeManager()
PagingManager	getPagingManager()
PostOffice	getPostOffice()
QueueFactory	getQueueFactory()
RemotingService	getRemotingService()
ReplicationManager	getReplicationManager()
ResourceManager	getResourceManager()
ScheduledExecutorService	getScheduledPool()
ActiveMQSecurityManager	getSecurityManager()
HierarchicalRepository<Set<Role>>	getSecurityRepository()
SecurityStore	getSecurityStore()
ServiceRegistry	getServiceRegistry()
ServerSession	getSessionByID(String sessionID)
Set<ServerSession>	getSessions()
List<ServerSession>	getSessions(String connectionID)
StorageManager	getStorageManager()
Version	getVersion()
boolean	hasScaledDown(SimpleString scaledDownNodeId)
boolean	isActive()
boolean	isAddressBound(String address) return true if there is a binding for this address (i.e.
Queue	locateQueue(SimpleString queueName)
ServerSession	lookupSession(String metakey, String metavalue)
void	registerActivateCallback(ActivateCallback callback)
void	removeProtocolManagerFactory(ProtocolManagerFactory factory)
void	removeSession(String name)
void	setGroupingHandler(GroupingHandler groupingHandler)
void	setHAPolicy(HAPolicy haPolicy)
void	setIdentity(String identity) Sets the server identity.
void	setJMSQueueCreator(QueueCreator queueCreator) This is the queue creator responsible for JMS Queue creations*
void	setMBeanServer(MBeanServer mBeanServer)
void	stop(boolean failoverOnServerShutdown)
void	threadDump()
void	unregisterActivateCallback(ActivateCallback callback)
boolean	waitForActivation(long timeout, TimeUnit unit) Wait for server initialization.

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

isStarted, start, stop

Method Detail

setIdentity

void setIdentity(String identity)

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.

getIdentity

String getIdentity()

describe

String describe()

addActivationParam

void addActivationParam(String key,
                        Object val)

getConfiguration

Configuration getConfiguration()

getServiceRegistry

ServiceRegistry getServiceRegistry()

getRemotingService

RemotingService getRemotingService()

getStorageManager

StorageManager getStorageManager()

getPagingManager

PagingManager getPagingManager()

getManagementService

ManagementService getManagementService()

getSecurityManager

ActiveMQSecurityManager getSecurityManager()

getVersion

Version getVersion()

getNodeManager

NodeManager getNodeManager()

getActiveMQServerControl

ActiveMQServerControlImpl getActiveMQServerControl()

Returns the resource to manage this ActiveMQ Artemis server.

Throws:

IllegalStateException - if the server is not properly started.

registerActivateCallback

void registerActivateCallback(ActivateCallback callback)

unregisterActivateCallback

void unregisterActivateCallback(ActivateCallback callback)

checkQueueCreationLimit

void checkQueueCreationLimit(String username)
                      throws Exception

Throws:

Exception

createSession

ServerSession createSession(String name,
                            String username,
                            String password,
                            int minLargeMessageSize,
                            RemotingConnection remotingConnection,
                            boolean autoCommitSends,
                            boolean autoCommitAcks,
                            boolean preAcknowledge,
                            boolean xa,
                            String defaultAddress,
                            SessionCallback callback,
                            ServerSessionFactory sessionFactory,
                            boolean autoCreateQueues)
                     throws Exception

Throws:

Exception

getSecurityStore

SecurityStore getSecurityStore()

removeSession

void removeSession(String name)
            throws Exception

Throws:

Exception

getSessions

Set<ServerSession> getSessions()

getSecurityRepository

HierarchicalRepository<Set<Role>> getSecurityRepository()

getAddressSettingsRepository

HierarchicalRepository<AddressSettings> getAddressSettingsRepository()

getConnectionCount

int getConnectionCount()

getPostOffice

PostOffice getPostOffice()

getQueueFactory

QueueFactory getQueueFactory()

getResourceManager

ResourceManager getResourceManager()

getSessions

List<ServerSession> getSessions(String connectionID)

lookupSession

ServerSession lookupSession(String metakey,
                            String metavalue)

Returns:

a session containing the meta-key and meata-value

getClusterManager

ClusterManager getClusterManager()

getNodeID

SimpleString getNodeID()

isActive

boolean isActive()

setJMSQueueCreator

void setJMSQueueCreator(QueueCreator queueCreator)

This is the queue creator responsible for JMS Queue creations*

Parameters:

queueCreator -

getJMSQueueCreator

QueueCreator getJMSQueueCreator()

See Also:

setJMSQueueCreator(QueueCreator)

waitForActivation

boolean waitForActivation(long timeout,
                          TimeUnit unit)
                   throws InterruptedException

Wait for server initialization.

Parameters:

timeout -

unit -

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)

createSharedQueue

void createSharedQueue(SimpleString address,
                       SimpleString name,
                       SimpleString filterString,
                       SimpleString user,
                       boolean durable)
                throws Exception

Creates a shared queue. if non durable it will exist as long as there are consumers. Notice: the queue won't be deleted until the first consumer arrives.

Parameters:

address -

name -

filterString -

durable -

Throws:

Exception

createQueue

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

Throws:

Exception

createQueue

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

Throws:

Exception

createQueue

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

Throws:

Exception

deployQueue

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

Throws:

Exception

locateQueue

Queue locateQueue(SimpleString queueName)

destroyQueue

void destroyQueue(SimpleString queueName)
           throws Exception

Throws:

Exception

destroyQueue

void destroyQueue(SimpleString queueName,
                  SecurityAuth session)
           throws Exception

Throws:

Exception

destroyQueue

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

Throws:

Exception

destroyQueue

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

Throws:

Exception

destroyConnectionWithSessionMetadata

String destroyConnectionWithSessionMetadata(String metaKey,
                                            String metaValue)
                                     throws Exception

Throws:

Exception

getScheduledPool

ScheduledExecutorService getScheduledPool()

getExecutorFactory

ExecutorFactory getExecutorFactory()

setGroupingHandler

void setGroupingHandler(GroupingHandler groupingHandler)

getGroupingHandler

GroupingHandler getGroupingHandler()

getReplicationManager

ReplicationManager getReplicationManager()

deployDivert

void deployDivert(DivertConfiguration config)
           throws Exception

Throws:

Exception

destroyDivert

void destroyDivert(SimpleString name)
            throws Exception

Throws:

Exception

getConnectorsService

ConnectorsService getConnectorsService()

deployBridge

void deployBridge(BridgeConfiguration config)
           throws Exception

Throws:

Exception

destroyBridge

void destroyBridge(String name)
            throws Exception

Throws:

Exception

getSessionByID

ServerSession getSessionByID(String sessionID)

threadDump

void threadDump()

isAddressBound

boolean isAddressBound(String address)
                throws Exception

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

Parameters:

address -

Returns:

Throws:

Exception

stop

void stop(boolean failoverOnServerShutdown)
   throws Exception

Throws:

Exception

addProtocolManagerFactory

void addProtocolManagerFactory(ProtocolManagerFactory factory)

removeProtocolManagerFactory

void removeProtocolManagerFactory(ProtocolManagerFactory factory)

createBackupServer

ActiveMQServer createBackupServer(Configuration configuration)

addScaledDownNode

void addScaledDownNode(SimpleString scaledDownNodeId)

hasScaledDown

boolean hasScaledDown(SimpleString scaledDownNodeId)

getActivation

Activation getActivation()

getHAPolicy

HAPolicy getHAPolicy()

setHAPolicy

void setHAPolicy(HAPolicy haPolicy)

setMBeanServer

void setMBeanServer(MBeanServer mBeanServer)