Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-5173 Avoiding exception on tests

This commit is contained in:
Clebert Suconic 2024-12-11 16:54:39 -05:00
parent ca8d57eb5e
commit 684d376da2
1 changed files with 11 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/largemessages/AMQPLargeMessagesTestUtil.java
View File

@ -40,21 +40,18 @@ public class AMQPLargeMessagesTestUtil {
public static void validateTemporaryBuffers(Queue serverQueue) {
LinkedListIterator<MessageReference> totalIterator = serverQueue.browserIterator();
while (totalIterator.hasNext()) {
MessageReference ref;
try {
ref = totalIterator.next();
} catch (NoSuchElementException e) {
// that's fine, it means the iterator got to the end of the list
// and something else removed it
break;
}
if (ref.getMessage() instanceof AMQPLargeMessage) {
AMQPLargeMessage amqpLargeMessage = (AMQPLargeMessage) ref.getMessage();
// Using a Wait.waitFor here as we may have something working with the buffer in parallel
Wait.waitFor(() -> amqpLargeMessage.inspectTemporaryBuffer() == null, 1000, 10);
assertNull(amqpLargeMessage.inspectTemporaryBuffer(), "Temporary buffers are being retained");
try {
while (totalIterator.hasNext()) {
MessageReference ref = totalIterator.next();
if (ref.getMessage() instanceof AMQPLargeMessage) {
AMQPLargeMessage amqpLargeMessage = (AMQPLargeMessage) ref.getMessage();
// Using a Wait.waitFor here as we may have something working with the buffer in parallel
Wait.waitFor(() -> amqpLargeMessage.inspectTemporaryBuffer() == null, 1000, 10);
assertNull(amqpLargeMessage.inspectTemporaryBuffer(), "Temporary buffers are being retained");
}
}
} catch (NoSuchElementException e) {
// that's ok
}
totalIterator.close();
}