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

NO-JIRA: fixing test

This commit is contained in:
Clebert Suconic 2017-07-06 09:18:28 -04:00
parent 89e84e1320
commit 01a5a60b37
4 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/ExpireWhileLoadBalanceTest.java
View File

@ -76,7 +76,7 @@ public class ExpireWhileLoadBalanceTest extends ClusterTestBase {
for (int i = 0; i <= 2; i++) {
createQueue(i, "queues.testaddress", "queue0", null, true);
getServer(i).createQueue(expiryQueue, RoutingType.ANYCAST, expiryQueue, null, true, false);
getServer(i).getAddressSettingsRepository().addMatch("queues.*", as);
getServer(i).getAddressSettingsRepository().addMatch("#", as);
}

4
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/failover/FailoverTest.java
View File

@ -370,7 +370,7 @@ public class FailoverTest extends FailoverTestBase {
}
session.end(xid, XAResource.TMSUCCESS);
session.prepare(xid);
crash(false, session);
crash(true, session);
try {
session.commit(xid, false);
@ -417,7 +417,7 @@ public class FailoverTest extends FailoverTestBase {
session.end(xid, XAResource.TMSUCCESS);
session.prepare(xid);
crash(false, session);
crash(true, session);
try {
session.rollback(xid);

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

@ -49,9 +49,9 @@ public class ReplicationFlowControlTest extends SmokeTestBase {
private static Process server1;
static final int NUM_MESSAGES = 300_000;
static final int START_CONSUMERS = 100_000;
static final int START_SERVER = 101_000;
static final int NUM_MESSAGES = 50_000;
static final int START_CONSUMERS = 10_000;
static final int START_SERVER = 15_000;
static final int NUMBER_OF_CONSUMERS = 10;
static final ReusableLatch latch = new ReusableLatch(NUM_MESSAGES);
@ -88,7 +88,7 @@ public class ReplicationFlowControlTest extends SmokeTestBase {
private void internalTest(boolean failover) throws Exception {
int KILL_SERVER = failover ? 150_000 : -1;
int KILL_SERVER = failover ? 50_000 : -1;
Connection connection = null;

4
tests/unit-tests/src/test/java/org/apache/activemq/artemis/tests/unit/core/journal/impl/JournalImplTestUnit.java
View File

@ -597,10 +597,6 @@ public abstract class JournalImplTestUnit extends JournalImplTestBase {
files1 = fileFactory.listFiles(fileExtension);
Assert.assertTrue(files1.size() > 200);
Assert.assertEquals(numberOfFiles, files1.size());
System.out.println("we have " + files1.size() + " files now");
stopJournal();
}