Package org.apache.activemq.artemis.util

Class ServerUtil

java.lang.Object

org.apache.activemq.artemis.util.ServerUtil

public class ServerUtil
extends Object

A tool to let clients start, stop and kill Artemis servers

Constructor Summary

Constructors

Constructor	Description
ServerUtil()

Method Summary

Modifier and Type	Method	Description
static Process	execute(String artemisInstance, String jobName, String... args)
static int	getServer(javax.jms.Connection connection)
static javax.jms.Connection	getServerConnection(int server, javax.jms.Connection... connections)
static void	killServer(Process server)
static void	killServer(Process server, boolean forcibly)
static Process	startServer(String artemisInstance, String serverName)
static Process	startServer(String artemisInstance, String serverName, int id, int timeout)
static Process	startServer(String artemisInstance, String serverName, int id, int timeout, File brokerProperties)
static Process	startServer(String artemisInstance, String serverName, String uri, int timeout)
static Process	startServer(String artemisInstance, String serverName, String uri, int timeout, File propertiesFile)
static boolean	waitForServerToStart(int id, int timeout)
static boolean	waitForServerToStart(int id, String username, String password, int timeout)
static boolean	waitForServerToStart(String uri, long timeout)
static boolean	waitForServerToStart(String uri, String username, String password, long timeout)
static boolean	waitForServerToStartOnPort(int port, String username, String password, int timeout)

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerUtil

public ServerUtil()

Method Detail

startServer

public static Process startServer(String artemisInstance,
                                  String serverName)
                           throws Exception

Throws:

Exception

startServer

public static Process startServer(String artemisInstance,
                                  String serverName,
                                  int id,
                                  int timeout)
                           throws Exception

Parameters:

artemisInstance -

serverName - it will be used on logs

id - it will be used to add on the port

timeout -

Returns:

Throws:

Exception

startServer

public static Process startServer(String artemisInstance,
                                  String serverName,
                                  int id,
                                  int timeout,
                                  File brokerProperties)
                           throws Exception

Throws:

Exception

startServer

public static Process startServer(String artemisInstance,
                                  String serverName,
                                  String uri,
                                  int timeout)
                           throws Exception

Throws:

Exception

startServer

public static Process startServer(String artemisInstance,
                                  String serverName,
                                  String uri,
                                  int timeout,
                                  File propertiesFile)
                           throws Exception

Throws:

Exception

execute

public static Process execute(String artemisInstance,
                              String jobName,
                              String... args)
                       throws IOException,
                              ClassNotFoundException

Throws:

IOException

ClassNotFoundException

waitForServerToStart

public static boolean waitForServerToStart(int id,
                                           int timeout)
                                    throws InterruptedException

Throws:

InterruptedException

waitForServerToStart

public static boolean waitForServerToStart(int id,
                                           String username,
                                           String password,
                                           int timeout)
                                    throws InterruptedException

Throws:

InterruptedException

waitForServerToStartOnPort

public static boolean waitForServerToStartOnPort(int port,
                                                 String username,
                                                 String password,
                                                 int timeout)
                                          throws InterruptedException

Throws:

InterruptedException

waitForServerToStart

public static boolean waitForServerToStart(String uri,
                                           long timeout)
                                    throws InterruptedException

Throws:

InterruptedException

waitForServerToStart

public static boolean waitForServerToStart(String uri,
                                           String username,
                                           String password,
                                           long timeout)
                                    throws InterruptedException

Throws:

InterruptedException

killServer

public static void killServer(Process server)
                       throws Exception

Throws:

Exception

killServer

public static void killServer(Process server,
                              boolean forcibly)
                       throws Exception

Throws:

Exception

getServer

public static int getServer(javax.jms.Connection connection)

getServerConnection

public static javax.jms.Connection getServerConnection(int server,
                                                       javax.jms.Connection... connections)