1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
|
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*
*/
package org.apache.qpid.server.queue;
import junit.framework.TestCase;
import org.apache.qpid.AMQException;
import org.apache.qpid.server.message.ServerMessage;
/**
* Abstract test class for QueueEntryList implementations.
*/
public abstract class QueueEntryListTestBase extends TestCase
{
protected static final AMQQueue _testQueue = new MockAMQQueue("test");
public abstract QueueEntryList<QueueEntry> getTestList();
public abstract long getExpectedFirstMsgId();
public abstract int getExpectedListLength();
public abstract ServerMessage getTestMessageToAdd() throws AMQException;
public void testGetQueue()
{
assertEquals("Unexpected head entry returned by getHead()", getTestList().getQueue(), _testQueue);
}
/**
* Test to add a message with properties specific to the queue type.
* @see QueueEntryListTestBase#getTestList()
* @see QueueEntryListTestBase#getTestMessageToAdd()
* @throws AMQException
*/
public void testAddSpecificMessage() throws AMQException
{
final QueueEntryList<QueueEntry> list = getTestList();
list.add(getTestMessageToAdd());
final QueueEntryIterator<?> iter = list.iterator();
int count = 0;
while(iter.advance())
{
iter.getNode();
count++;
}
assertEquals("List did not grow by one entry after an add", getExpectedListLength() + 1, count);
}
/**
* Test to add a generic mock message.
* @see QueueEntryListTestBase#getTestList()
* @see QueueEntryListTestBase#getExpectedListLength()
* @see MockAMQMessage
* @throws AMQException
*/
public void testAddGenericMessage() throws AMQException
{
final QueueEntryList<QueueEntry> list = getTestList();
list.add(new MockAMQMessage(666));
final QueueEntryIterator<?> iter = list.iterator();
int count = 0;
while(iter.advance())
{
iter.getNode();
count++;
}
assertEquals("List did not grow by one entry after a generic message added", getExpectedListLength() + 1, count);
}
/**
* Test for getting the next element in a queue list.
* @see QueueEntryListTestBase#getTestList()
* @see QueueEntryListTestBase#getExpectedListLength()
*/
public void testListNext()
{
final QueueEntryList<QueueEntry> entryList = getTestList();
QueueEntry entry = entryList.getHead();
int count = 0;
while(entryList.next(entry) != null)
{
entry = entryList.next(entry);
count++;
}
assertEquals("Get next didnt get all the list entries", getExpectedListLength(), count);
}
/**
* Basic test for the associated QueueEntryIterator implementation.
* @see QueueEntryListTestBase#getTestList()
* @see QueueEntryListTestBase#getExpectedListLength()
*/
public void testIterator()
{
final QueueEntryIterator<?> iter = getTestList().iterator();
int count = 0;
while(iter.advance())
{
iter.getNode();
count++;
}
assertEquals("Iterator invalid", getExpectedListLength(), count);
}
/**
* Test for associated QueueEntryIterator implementation that checks it handles "removed" messages.
* @see QueueEntryListTestBase#getTestList()
* @see QueueEntryListTestBase#getExpectedListLength()
*/
public void testDequedMessagedNotPresentInIterator() throws Exception
{
final int numberOfMessages = getExpectedListLength();
final QueueEntryList<QueueEntry> entryList = getTestList();
// dequeue all even messages
final QueueEntryIterator<?> it1 = entryList.iterator();
int counter = 0;
while (it1.advance())
{
final QueueEntry queueEntry = it1.getNode();
if(counter++ % 2 == 0)
{
queueEntry.acquire();
queueEntry.dequeue();
}
}
// iterate and check that dequeued messages are not returned by iterator
final QueueEntryIterator<?> it2 = entryList.iterator();
int counter2 = 0;
while(it2.advance())
{
it2.getNode();
counter2++;
}
final int expectedNumber = numberOfMessages / 2;
assertEquals("Expected " + expectedNumber + " number of entries in iterator but got " + counter2,
expectedNumber, counter2);
}
/**
* Test to verify the head of the queue list is returned as expected.
* @see QueueEntryListTestBase#getTestList()
* @see QueueEntryListTestBase#getExpectedFirstMsgId()
*/
public void testGetHead()
{
final QueueEntry head = getTestList().getHead();
assertNull("Head entry should not contain an actual message", head.getMessage());
assertEquals("Unexpected message id for first list entry", getExpectedFirstMsgId(), getTestList().next(head)
.getMessage().getMessageNumber());
}
/**
* Test to verify the entry deletion handled correctly.
* @see QueueEntryListTestBase#getTestList()
*/
public void testEntryDeleted()
{
final QueueEntry head = getTestList().getHead();
final QueueEntry first = getTestList().next(head);
first.delete();
final QueueEntry second = getTestList().next(head);
assertNotSame("After deletion the next entry should be different", first.getMessage().getMessageNumber(), second
.getMessage().getMessageNumber());
final QueueEntry third = getTestList().next(first);
assertEquals("After deletion the deleted nodes next node should be the same as the next from head", second
.getMessage().getMessageNumber(), third.getMessage().getMessageNumber());
}
}
|
