summaryrefslogtreecommitdiff
path: root/java/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryTest.java
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-02-17 20:19:36 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-02-17 20:19:36 +0000
commitadd5c695d1138bc25bb89cd0e1b1724bf542f676 (patch)
treef222dd1710831dc383ada64bc4479bcfd4c8bbc4 /java/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryTest.java
parente31aa33452bd54ce118078ad38d8291cc3a3d1db (diff)
downloadqpid-python-add5c695d1138bc25bb89cd0e1b1724bf542f676.tar.gz
Update Queue implementation to better define lifetime and exclusivity policiesjava-broker-amqp-1-0-management
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-amqp-1-0-management@1569102 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryTest.java')
-rw-r--r--java/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryTest.java14
1 files changed, 13 insertions, 1 deletions
diff --git a/java/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryTest.java b/java/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryTest.java
index 25d6dbba60..e55875135a 100644
--- a/java/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryTest.java
+++ b/java/broker-core/src/test/java/org/apache/qpid/server/queue/SortedQueueEntryTest.java
@@ -20,11 +20,15 @@
package org.apache.qpid.server.queue;
import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
import java.util.UUID;
import org.apache.qpid.server.message.AMQMessageHeader;
import org.apache.qpid.server.message.MessageReference;
import org.apache.qpid.server.message.ServerMessage;
+import org.apache.qpid.server.model.LifetimePolicy;
+import org.apache.qpid.server.model.Queue;
import org.apache.qpid.server.virtualhost.VirtualHost;
import static org.mockito.Matchers.eq;
@@ -42,7 +46,15 @@ public class SortedQueueEntryTest extends QueueEntryImplTestBase
public void setUp() throws Exception
{
mockLogging();
- SortedQueue queue = new SortedQueue(UUID.randomUUID(), getName(), false, null, false,false, mock(VirtualHost.class), null, "KEY", new QueueEntryListFactory<SortedQueueEntry,SortedQueue,SortedQueueEntryList>()
+
+ Map<String,Object> attributes = new HashMap<String,Object>();
+ attributes.put(Queue.ID,UUID.randomUUID());
+ attributes.put(Queue.NAME, getName());
+ attributes.put(Queue.DURABLE, false);
+ attributes.put(Queue.LIFETIME_POLICY, LifetimePolicy.PERMANENT);
+ attributes.put(Queue.SORT_KEY, "KEY");
+
+ SortedQueue queue = new SortedQueue(mock(VirtualHost.class), null, attributes, new QueueEntryListFactory<SortedQueueEntry,SortedQueue,SortedQueueEntryList>()
{
@Override