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

derby on virtual hw can be very slow, so a query with an intentionally large backlog can take some time 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1431494 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2013-01-10 16:51:12 +00:00
parent 6e36321669
commit 7d2ac2d936
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-core/src/test/java/org/apache/activemq/store/MessagePriorityTest.java
View File

@ -575,8 +575,9 @@ abstract public class MessagePriorityTest extends CombinationTestSupport {
LOG.info("Starting consumer..."); LOG.info("Starting consumer...");
MessageConsumer queueConsumer = sess.createConsumer(queue); MessageConsumer queueConsumer = sess.createConsumer(queue);
for (int i = 0; i < 500; i++) { for (int i = 0; i < 500; i++) {
Message msg = queueConsumer.receive(5000); Message msg = queueConsumer.receive(20000);
LOG.debug("received i=" + i + ", " + (msg!=null? msg.getJMSMessageID() : null)); LOG.debug("received i=" + i + ", " + (msg!=null? msg.getJMSMessageID() : null));
if (msg == null) dumpAllThreads("backlog");
assertNotNull("Message " + i + " was null", msg); assertNotNull("Message " + i + " was null", msg);
assertEquals("Message " + i + " has wrong priority", i < 10 ? HIGH_PRI : LOW_PRI, msg.getJMSPriority()); assertEquals("Message " + i + " has wrong priority", i < 10 ? HIGH_PRI : LOW_PRI, msg.getJMSPriority());
} }