Author: ritchiem
Date: Thu Dec 11 03:19:31 2008
New Revision: 725663
URL: http://svn.apache.org/viewvc?rev=725663&view=rev
Log:
QPID-1524 : Added a catch to print out the message order to help rule out
message loss potential in the test.
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=725663&r1=725662&r2=725663&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
Thu Dec 11 03:19:31 2008
@@ -25,6 +25,7 @@
import org.apache.qpid.AMQException;
import org.apache.qpid.framing.BasicContentHeaderProperties;
import org.apache.qpid.framing.FieldTable;
+import junit.framework.AssertionFailedError;
public class AMQPriorityQueueTest extends SimpleAMQQueueTest
{
@@ -60,17 +61,33 @@
Thread.sleep(150);
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());
-
- assertEquals(new Long(2L), msgs.get(3).getMessage().getMessageId());
- assertEquals(new Long(5L), msgs.get(4).getMessage().getMessageId());
- assertEquals(new Long(7L), msgs.get(5).getMessage().getMessageId());
-
- assertEquals(new Long(3L), msgs.get(6).getMessage().getMessageId());
- assertEquals(new Long(4L), msgs.get(7).getMessage().getMessageId());
- assertEquals(new Long(9L), msgs.get(8).getMessage().getMessageId());
+ try
+ {
+ 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());
+
+ assertEquals(new Long(2L),
msgs.get(3).getMessage().getMessageId());
+ assertEquals(new Long(5L),
msgs.get(4).getMessage().getMessageId());
+ assertEquals(new Long(7L),
msgs.get(5).getMessage().getMessageId());
+
+ assertEquals(new Long(3L),
msgs.get(6).getMessage().getMessageId());
+ assertEquals(new Long(4L),
msgs.get(7).getMessage().getMessageId());
+ assertEquals(new Long(9L),
msgs.get(8).getMessage().getMessageId());
+ }
+ catch (AssertionFailedError afe)
+ {
+ // Show message order on failure.
+ int index = 1;
+ for (QueueEntry qe : msgs)
+ {
+ System.err.println(index + ":" +
qe.getMessage().getMessageId());
+ index++;
+ }
+
+ throw afe;
+ }
+
}
protected AMQMessage createMessage(Long id, byte i) throws AMQException
