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

This commit is contained in:
jbertram 2016-07-15 09:38:17 -05:00
parent baee468de2 4d16c0721a
commit 9df39ad569
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/jms/server/management/JMSQueueControlTest.java
View File

@ -46,6 +46,7 @@ import org.apache.activemq.artemis.api.core.client.ServerLocator;
import org.apache.activemq.artemis.api.core.management.ObjectNameBuilder;
import org.apache.activemq.artemis.api.jms.ActiveMQJMSClient;
import org.apache.activemq.artemis.api.jms.JMSFactoryType;
import org.apache.activemq.artemis.api.jms.management.DestinationControl;
import org.apache.activemq.artemis.api.jms.management.JMSQueueControl;
import org.apache.activemq.artemis.api.jms.management.JMSServerControl;
import org.apache.activemq.artemis.core.config.Configuration;
@ -1451,6 +1452,8 @@ public class JMSQueueControlTest extends ManagementTestBase {
JMSQueueControl control = createManagementControl(pagedQueue);
Assert.assertTrue(waitForMessages(control, 100, 5000));
assertEquals(100, control.removeMessages(" "));
session.start();
@ -1667,6 +1670,18 @@ public class JMSQueueControlTest extends ManagementTestBase {
return ManagementControlHelper.createJMSQueueControl(queueParameter, mbeanServer);
}
protected boolean waitForMessages(DestinationControl control, int count, long timeout) throws Exception {
long timeToWait = System.currentTimeMillis() + timeout;
while (System.currentTimeMillis() < timeToWait) {
if (control.getMessageCount() == count) {
return true;
}
Thread.sleep(100);
}
return false;
}
// Private -------------------------------------------------------
private Connection createConnection() throws JMSException {