NO-JIRA Another fix on FailoverTest::testTimeoutOnFailoverConsumer

This commit is contained in:
Clebert Suconic 2019-07-23 23:02:40 -04:00
parent 549e167a5a
commit 5c05cce109
1 changed files with 3 additions and 3 deletions

View File

@ -176,12 +176,12 @@ public class FailoverTest extends FailoverTestBase {
}
// https://issues.jboss.org/browse/HORNETQ-685
@Test
@Test(timeout = 120000)
public void testTimeoutOnFailoverConsume() throws Exception {
locator.setCallTimeout(100).setBlockOnNonDurableSend(true).setBlockOnDurableSend(true).setAckBatchSize(0).setBlockOnAcknowledge(true).setReconnectAttempts(300).setRetryInterval(10).setAckBatchSize(0);
locator.setCallTimeout(1000).setBlockOnNonDurableSend(true).setBlockOnDurableSend(true).setAckBatchSize(0).setBlockOnAcknowledge(true).setReconnectAttempts(-1).setRetryInterval(10).setAckBatchSize(0);
if (nodeManager instanceof InVMNodeManager) {
((InVMNodeManager) nodeManager).failoverPause = 500L;
((InVMNodeManager) nodeManager).failoverPause = 2000L;
}
ClientSessionFactoryInternal sf1 = (ClientSessionFactoryInternal) createSessionFactory(locator);