summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src
diff options
context:
space:
mode:
authorAidan Skinner <aidan@apache.org>2008-09-19 15:25:55 +0000
committerAidan Skinner <aidan@apache.org>2008-09-19 15:25:55 +0000
commit3c2f204cb75b62ab0cd202f898558123637d45bf (patch)
tree899884320511b8fd80fe6a86ef6ca230021afca6 /qpid/java/broker/src
parent0d1daf623f9820887028ec0a7bafbfff06ed08ec (diff)
downloadqpid-python-3c2f204cb75b62ab0cd202f898558123637d45bf.tar.gz
QPID-1286: Change test and variable names as per review.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@697131 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src')
-rw-r--r--qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java26
1 files changed, 13 insertions, 13 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java
index e479a1e489..42d0d6fe2d 100644
--- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java
+++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQPriorityQueueTest.java
@@ -32,8 +32,8 @@ public class AMQPriorityQueueTest extends SimpleAMQQueueTest
@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 @@ public class AMQPriorityQueueTest extends SimpleAMQQueueTest
{
// 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());