ARTEMIS-290 PageCountSyncOnNonTXTest.testSendNoTx: fails on slower machines
This commit is contained in:
parent
73f8fbf4c7
commit
effe95c0ba
|
@ -30,8 +30,13 @@ import org.apache.activemq.artemis.tests.util.ActiveMQTestBase;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import java.util.concurrent.CountDownLatch;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
public class PageCountSyncOnNonTXTest extends ActiveMQTestBase {
|
public class PageCountSyncOnNonTXTest extends ActiveMQTestBase {
|
||||||
|
|
||||||
|
public static final String WORD_START = "&*STARTED&*";
|
||||||
|
|
||||||
// We will add a random factor on the wait time
|
// We will add a random factor on the wait time
|
||||||
private long timeToRun;
|
private long timeToRun;
|
||||||
|
|
||||||
|
@ -49,7 +54,16 @@ public class PageCountSyncOnNonTXTest extends ActiveMQTestBase {
|
||||||
public void testSendNoTx() throws Exception {
|
public void testSendNoTx() throws Exception {
|
||||||
String QUEUE_NAME = "myQueue";
|
String QUEUE_NAME = "myQueue";
|
||||||
|
|
||||||
process = PageCountSyncServer.spawnVM(getTestDir(), timeToRun);
|
final CountDownLatch latch = new CountDownLatch(1);
|
||||||
|
Runnable runnable = new Runnable() {
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
latch.countDown();
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
process = PageCountSyncServer.spawnVMWithLogMacher(WORD_START, runnable, getTestDir(), timeToRun);
|
||||||
|
assertTrue("Server didn't start in 30 seconds", latch.await(30, TimeUnit.SECONDS));
|
||||||
|
|
||||||
ServerLocator locator = createNettyNonHALocator();
|
ServerLocator locator = createNettyNonHALocator();
|
||||||
|
|
||||||
|
|
|
@ -30,6 +30,10 @@ public class PageCountSyncServer extends SpawnedServerSupport {
|
||||||
return SpawnedVMSupport.spawnVM(PageCountSyncServer.class.getName(), testDir, "" + timeToRun);
|
return SpawnedVMSupport.spawnVM(PageCountSyncServer.class.getName(), testDir, "" + timeToRun);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static Process spawnVMWithLogMacher(final String wordMatch, final Runnable runnable, final String testDir, final long timeToRun) throws Exception {
|
||||||
|
return SpawnedVMSupport.spawnVMWithLogMacher(wordMatch, runnable, PageCountSyncServer.class.getName(), null, true, testDir, "" + timeToRun);
|
||||||
|
}
|
||||||
|
|
||||||
public void perform(final String folder, final long timeToRun) throws Exception {
|
public void perform(final String folder, final long timeToRun) throws Exception {
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
@ -37,6 +41,7 @@ public class PageCountSyncServer extends SpawnedServerSupport {
|
||||||
|
|
||||||
server.start();
|
server.start();
|
||||||
|
|
||||||
|
System.out.println(PageCountSyncOnNonTXTest.WORD_START);
|
||||||
System.out.println("Server started!!!");
|
System.out.println("Server started!!!");
|
||||||
|
|
||||||
System.out.println("Waiting " + timeToRun + " seconds");
|
System.out.println("Waiting " + timeToRun + " seconds");
|
||||||
|
|
Loading…
Reference in New Issue