| commit | 2ee3d0c9de5b203387137a98e8a50e419fc9942e | [log] [tgz] |
|---|---|---|
| author | Alex Rudyy <orudyy@apache.org> | Thu Jan 09 13:30:28 2020 +0000 |
| committer | Alex Rudyy <orudyy@apache.org> | Thu Jan 09 13:30:43 2020 +0000 |
| tree | e0e94324b77586ca0f2a0f3bfe99b59626e61068 | |
| parent | 3be99603f5ef444db0b65fa8f20a806698eb3043 [diff] |
[NO-JIRA] Ensure destructive consumer is used in test LastValueQueueTest#testParallelProductionAndConsumption
diff --git a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/queue/LastValueQueueTest.java b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/queue/LastValueQueueTest.java index 0c827eb..fd90354 100644 --- a/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/queue/LastValueQueueTest.java +++ b/systests/qpid-systests-jms_1.1/src/test/java/org/apache/qpid/systests/jms_1_1/extensions/queue/LastValueQueueTest.java
@@ -325,7 +325,7 @@ public void testParallelProductionAndConsumption() throws Exception { final String queueName = getTestName(); - final Queue queue = createConflationQueue(queueName, KEY_PROPERTY, true); + final Queue queue = createConflationQueue(queueName, KEY_PROPERTY, false); int numberOfUniqueKeyValues = 2; final ExecutorService executorService = Executors.newFixedThreadPool(2);