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

On a loaded or very slow machine these can fail without a bit more time on the timeout. Was able to reproduce locally with video encoders running. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1347824 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2012-06-07 22:59:47 +00:00
parent 0a8e505b14
commit 06a42763c5
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/test/java/org/apache/activemq/usecases/LargeQueueSparseDeleteTest.java
View File

@ -23,12 +23,12 @@ import javax.jms.MessageProducer;
import javax.jms.Session; import javax.jms.Session;
import org.apache.activemq.EmbeddedBrokerTestSupport; import org.apache.activemq.EmbeddedBrokerTestSupport;
import org.apache.activemq.filter.NonCachedMessageEvaluationContext;
import org.apache.activemq.broker.region.Queue;
import org.apache.activemq.broker.ConnectionContext; import org.apache.activemq.broker.ConnectionContext;
import org.apache.activemq.broker.region.Queue;
import org.apache.activemq.filter.NonCachedMessageEvaluationContext;
import org.junit.Assert;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.junit.Assert;
/** /**
* This unit test creates a fixed size queue and moves the last message in the * This unit test creates a fixed size queue and moves the last message in the
@ -59,7 +59,7 @@ public class LargeQueueSparseDeleteTest extends EmbeddedBrokerTestSupport {
final int QUEUE_SIZE = 30000; final int QUEUE_SIZE = 30000;
final String MOVE_TO_DESTINATION_NAME = getDestinationString() final String MOVE_TO_DESTINATION_NAME = getDestinationString()
+ ".dest"; + ".dest";
final long TEST_TIMEOUT = 6000; final long TEST_TIMEOUT = 8000;
// Populate a test queue with uniquely-identifiable messages. // Populate a test queue with uniquely-identifiable messages.
Connection conn = createConnection(); Connection conn = createConnection();
@ -108,7 +108,7 @@ public class LargeQueueSparseDeleteTest extends EmbeddedBrokerTestSupport {
final int QUEUE_SIZE = 30000; final int QUEUE_SIZE = 30000;
final String MOVE_TO_DESTINATION_NAME = getDestinationString() final String MOVE_TO_DESTINATION_NAME = getDestinationString()
+ ".dest"; + ".dest";
final long TEST_TIMEOUT = 6000; final long TEST_TIMEOUT = 8000;
// Populate a test queue with uniquely-identifiable messages. // Populate a test queue with uniquely-identifiable messages.
Connection conn = createConnection(); Connection conn = createConnection();
@ -154,7 +154,7 @@ public class LargeQueueSparseDeleteTest extends EmbeddedBrokerTestSupport {
public void testRemoveMessages() throws Exception { public void testRemoveMessages() throws Exception {
final int QUEUE_SIZE = 30000; final int QUEUE_SIZE = 30000;
final long TEST_TIMEOUT = 6000; final long TEST_TIMEOUT = 8000;
// Populate a test queue with uniquely-identifiable messages. // Populate a test queue with uniquely-identifiable messages.
Connection conn = createConnection(); Connection conn = createConnection();