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

Class EmbeddedActiveMQ

java.lang.Object

org.apache.activemq.artemis.core.server.embedded.EmbeddedActiveMQ

Direct Known Subclasses:

EmbeddedJMS

public class EmbeddedActiveMQ
extends Object

Helper class to simplify bootstrap of ActiveMQ Artemis server. Bootstraps from classpath-based config files.

Field Summary

Fields

Modifier and Type	Field	Description
protected ActiveMQServer	activeMQServer
protected String	configResourcePath
protected Configuration	configuration
protected MBeanServer	mbeanServer
protected String	propertiesResourcePath
protected ActiveMQSecurityManager	securityManager

Constructor Summary

Constructors

Constructor	Description
EmbeddedActiveMQ()

Method Summary

Modifier and Type	Method	Description
void	createActiveMQServer()
ActiveMQServer	getActiveMQServer()
Configuration	getConfiguration()
EmbeddedActiveMQ	setConfigResourcePath(String filename)	Classpath resource for activemq server config.
EmbeddedActiveMQ	setConfiguration(Configuration configuration)	Set this object if you are not using file-based configuration.
EmbeddedActiveMQ	setMbeanServer(MBeanServer mbeanServer)	Use this mbean server to register management beans.
EmbeddedActiveMQ	setPropertiesResourcePath(String filename)	Classpath resource for broker properties file.
EmbeddedActiveMQ	setSecurityManager(ActiveMQSecurityManager securityManager)	Set the activemq security manager.
EmbeddedActiveMQ	start()
EmbeddedActiveMQ	stop()
boolean	waitClusterForming(long timeWait, TimeUnit unit, int iterations, int servers)	It will iterate the cluster connections until you have at least the number of expected servers

Methods inherited from class java.lang.Object

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

Field Details

securityManager

protected ActiveMQSecurityManager securityManager

configResourcePath

protected String configResourcePath

configuration

protected Configuration configuration

activeMQServer

protected ActiveMQServer activeMQServer

mbeanServer

protected MBeanServer mbeanServer

propertiesResourcePath

protected String propertiesResourcePath

Constructor Details

EmbeddedActiveMQ

public EmbeddedActiveMQ()

Method Details

setConfigResourcePath

public EmbeddedActiveMQ setConfigResourcePath(String filename)

Classpath resource for activemq server config. Defaults to 'broker.xml'.

setPropertiesResourcePath

public EmbeddedActiveMQ setPropertiesResourcePath(String filename)

Classpath resource for broker properties file. Defaults to 'broker.properties'.

setSecurityManager

public EmbeddedActiveMQ setSecurityManager(ActiveMQSecurityManager securityManager)

Set the activemq security manager. This defaults to org.apache.activemq.artemis.spi.core.security.ActiveMQSecurityManagerImpl

waitClusterForming

public boolean waitClusterForming(long timeWait,
 TimeUnit unit,
 int iterations,
 int servers)
                           throws Exception

It will iterate the cluster connections until you have at least the number of expected servers

Parameters:

timeWait - Time to wait on each iteration

unit - unit of time to wait

iterations - number of iterations

servers - number of minimal servers

Throws:

Exception

setMbeanServer

public EmbeddedActiveMQ setMbeanServer(MBeanServer mbeanServer)

Use this mbean server to register management beans. If not set, no mbeans will be registered.

setConfiguration

public EmbeddedActiveMQ setConfiguration(Configuration configuration)

Set this object if you are not using file-based configuration. The default implementation will load configuration from a file.

getConfiguration

public Configuration getConfiguration()

getActiveMQServer

public ActiveMQServer getActiveMQServer()

start

public EmbeddedActiveMQ start()
                       throws Exception

Throws:

Exception

createActiveMQServer

public void createActiveMQServer()
                          throws Exception

Throws:

Exception

stop

public EmbeddedActiveMQ stop()
                      throws Exception

Throws:

Exception