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 Speeding up AddressqueueDeleteDelayTest

This commit is contained in:
Clebert Suconic 2021-02-01 11:26:53 -05:00
parent d186d20406
commit 1ed52cc5b0
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/AddressQueueDeleteDelayTest.java
View File

@ -41,6 +41,7 @@ public class AddressQueueDeleteDelayTest extends ActiveMQTestBase {
private static final Logger log = Logger.getLogger(AddressQueueDeleteDelayTest.class); private static final Logger log = Logger.getLogger(AddressQueueDeleteDelayTest.class);
public static final int DURATION_MILLIS = 30_000; public static final int DURATION_MILLIS = 30_000;
public static final int NEGATIVE_DURATION_MILLIS = 1_000;
public static final int SLEEP_MILLIS = 100; public static final int SLEEP_MILLIS = 100;
private ActiveMQServer server; private ActiveMQServer server;
@ -196,7 +197,8 @@ public class AddressQueueDeleteDelayTest extends ActiveMQTestBase {
session.createQueue(new QueueConfiguration(queue).setAddress(address)); session.createQueue(new QueueConfiguration(queue).setAddress(address));
session.deleteQueue(queue); session.deleteQueue(queue);
assertFalse(Wait.waitFor(() -> server.getAddressInfo(address) == null, DURATION_MILLIS, SLEEP_MILLIS)); Thread.sleep(1000); // waiting some time so the delay would kick in if misconfigured
Assert.assertTrue(server.getAddressInfo(address) != null);
} }
@Test @Test
@ -213,7 +215,8 @@ public class AddressQueueDeleteDelayTest extends ActiveMQTestBase {
session.createQueue(new QueueConfiguration(queue).setAddress(address)); session.createQueue(new QueueConfiguration(queue).setAddress(address));
session.deleteQueue(queue); session.deleteQueue(queue);
assertFalse(Wait.waitFor(() -> server.getAddressInfo(address) == null, DURATION_MILLIS, SLEEP_MILLIS)); Thread.sleep(1000); // waiting some time so the delay would kick in if misconfigured
Assert.assertTrue(server.getAddressInfo(address) != null);
} }
@Override @Override