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 #256

This commit is contained in:
Clebert Suconic 2015-12-07 13:39:53 -05:00
parent deb84857a6 ae22fa2a5d
commit a95784096d
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/ra/ActiveMQClusteredTest.java
View File

@ -172,7 +172,16 @@ public class ActiveMQClusteredTest extends ActiveMQRAClusteredTestBase {
} }
@Test @Test
public void testRebalance() throws Exception { public void testRebalanceWithInfiniteReconnect() throws Exception {
testRebalanceInternal(-1);
}
@Test
public void testRebalanceWithNoReconnect() throws Exception {
testRebalanceInternal(0);
}
public void testRebalanceInternal(int reconnectAttempts) throws Exception {
final int CONSUMER_COUNT = 10; final int CONSUMER_COUNT = 10;
secondaryJmsServer.createQueue(true, MDBQUEUE, null, true, "/jms/" + MDBQUEUE); secondaryJmsServer.createQueue(true, MDBQUEUE, null, true, "/jms/" + MDBQUEUE);
@ -188,6 +197,7 @@ public class ActiveMQClusteredTest extends ActiveMQRAClusteredTestBase {
spec.setMaxSession(CONSUMER_COUNT); spec.setMaxSession(CONSUMER_COUNT);
spec.setSetupAttempts(5); spec.setSetupAttempts(5);
spec.setSetupInterval(200); spec.setSetupInterval(200);
spec.setReconnectAttempts(reconnectAttempts);
spec.setHA(true); // if this isn't true then the toplogy listener won't get nodeDown notifications spec.setHA(true); // if this isn't true then the toplogy listener won't get nodeDown notifications
spec.setCallTimeout(500L); // if this isn't set then it may take a long time for tearDown to occur on the MDB connection spec.setCallTimeout(500L); // if this isn't set then it may take a long time for tearDown to occur on the MDB connection
qResourceAdapter.setConnectorClassName(INVM_CONNECTOR_FACTORY); qResourceAdapter.setConnectorClassName(INVM_CONNECTOR_FACTORY);