Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #3080

This commit is contained in:
Clebert Suconic 2020-04-14 11:49:42 -04:00
parent b9ff5a1e8d 9e9f88b6b7
commit 5085fabd9a
4 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
artemis-cli/src/main/java/org/apache/activemq/artemis/util/ServerUtil.java
View File

@ -105,11 +105,19 @@ public class ServerUtil {
}
public static void killServer(final Process server) throws Exception {
killServer(server, false);
}
public static void killServer(final Process server, boolean forcibly) throws Exception {
if (server != null) {
System.out.println("**********************************");
System.out.println("Killing server " + server);
System.out.println("**********************************");
server.destroyForcibly();
if (forcibly) {
server.destroyForcibly();
} else {
server.destroy();
}
server.waitFor();
Thread.sleep(1000);
}

2
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/common/SmokeTestBase.java
View File

@ -33,7 +33,7 @@ public class SmokeTestBase extends ActiveMQTestBase {
public void after() throws Exception {
for (Process process : processes) {
try {
ServerUtil.killServer(process);
ServerUtil.killServer(process, true);
} catch (Throwable e) {
e.printStackTrace();
}

2
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/mqtt/MQTTLeakTest.java
View File

@ -60,7 +60,7 @@ public class MQTTLeakTest extends SmokeTestBase {
MQTTRunner.run();
} finally {
ServerUtil.killServer(server0);
ServerUtil.killServer(server0, true);
}
}

2
tests/smoke-tests/src/test/java/org/apache/activemq/artemis/tests/smoke/replicationflow/ReplicationFlowControlTest.java
View File

@ -122,7 +122,7 @@ public class ReplicationFlowControlTest extends SmokeTestBase {
if (KILL_SERVER >= 0 && i == KILL_SERVER) {
session.commit();
System.out.println("Killing server");
ServerUtil.killServer(server0);
ServerUtil.killServer(server0, true);
Thread.sleep(2000);
connection.close();
connection = connectionFactory.createConnection();