You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ai...@apache.org on 2008/09/19 17:25:55 UTC
svn commit: r697131 - /incubator/qpid/trunk/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java

Author: aidan
Date: Fri Sep 19 08:25:55 2008
New Revision: 697131

URL: http://svn.apache.org/viewvc?rev=697131&view=rev
Log:
QPID-1286: Change test and variable names as per review.

Modified:
    incubator/qpid/trunk/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java

Modified: incubator/qpid/trunk/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java?rev=697131&r1=697130&r2=697131&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java (original)
+++ incubator/qpid/trunk/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java Fri Sep 19 08:25:55 2008
@@ -32,8 +32,8 @@
     @Override
     protected void setUp() throws Exception
     {
-        arguments = new FieldTable();
-        arguments.put(AMQQueueFactory.X_QPID_PRIORITIES, 3);
+        _arguments = new FieldTable();
+        _arguments.put(AMQQueueFactory.X_QPID_PRIORITIES, 3);
         super.setUp();
     }
 
@@ -41,25 +41,25 @@
     {
 
         // Enqueue messages in order
-        queue.enqueue(null, createMessage(1L, (byte) 10));
-        queue.enqueue(null, createMessage(2L, (byte) 4));
-        queue.enqueue(null, createMessage(3L, (byte) 0));
+        _queue.enqueue(null, createMessage(1L, (byte) 10));
+        _queue.enqueue(null, createMessage(2L, (byte) 4));
+        _queue.enqueue(null, createMessage(3L, (byte) 0));
         
         // Enqueue messages in reverse order
-        queue.enqueue(null, createMessage(4L, (byte) 0));
-        queue.enqueue(null, createMessage(5L, (byte) 4));
-        queue.enqueue(null, createMessage(6L, (byte) 10));
+        _queue.enqueue(null, createMessage(4L, (byte) 0));
+        _queue.enqueue(null, createMessage(5L, (byte) 4));
+        _queue.enqueue(null, createMessage(6L, (byte) 10));
         
         // Enqueue messages out of order
-        queue.enqueue(null, createMessage(7L, (byte) 4));
-        queue.enqueue(null, createMessage(8L, (byte) 10));
-        queue.enqueue(null, createMessage(9L, (byte) 0));
+        _queue.enqueue(null, createMessage(7L, (byte) 4));
+        _queue.enqueue(null, createMessage(8L, (byte) 10));
+        _queue.enqueue(null, createMessage(9L, (byte) 0));
         
         // Register subscriber
-        queue.registerSubscription(subscription, false);
+        _queue.registerSubscription(_subscription, false);
         Thread.sleep(150);
         
-        ArrayList<QueueEntry> msgs = subscription.getMessages();
+        ArrayList<QueueEntry> msgs = _subscription.getMessages();
         assertEquals(new Long(1L), msgs.get(0).getMessage().getMessageId());
         assertEquals(new Long(6L), msgs.get(1).getMessage().getMessageId());
         assertEquals(new Long(8L), msgs.get(2).getMessage().getMessageId());