From bdc299df1de6ca9dcd093040f00ff965692efeb0 Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Tue, 8 Jun 2010 15:33:42 +0000 Subject: QPID-2650: make PST check the recovered messages more precisely, and more informative about the unexpected message it recieves when it fails git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@952694 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/server/store/PersistentStoreTest.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) (limited to 'java') diff --git a/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java b/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java index b614392681..979a27789a 100644 --- a/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java +++ b/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java @@ -32,6 +32,7 @@ import javax.jms.MessageConsumer; import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.Session; + import java.util.ArrayList; import java.util.List; @@ -49,7 +50,7 @@ public class PersistentStoreTest extends QpidBrokerTestCase super.setUp(); _con = getConnection(); _con.start(); - _session = _con.createSession(true, Session.AUTO_ACKNOWLEDGE); + _session = _con.createSession(true, Session.SESSION_TRANSACTED); _destination = _session.createQueue(getTestQueueName()); _consumer = _session.createConsumer(_destination); _consumer.close(); @@ -69,8 +70,14 @@ public class PersistentStoreTest extends QpidBrokerTestCase { Message msg = _consumer.receive(RECEIVE_TIMEOUT); assertNotNull("Message " + i + " not received", msg); + assertEquals("Did not recieve the expected message", i, msg.getIntProperty(INDEX)); + } + + Message msg = _consumer.receive(100); + if(msg != null) + { + fail("No more messages should be received, but received message: " + msg.getIntProperty(INDEX)); } - assertNull("No more messages should be received", _consumer.receive(100)); } // /** @@ -119,6 +126,7 @@ public class PersistentStoreTest extends QpidBrokerTestCase public void testForcibleStartStopMidTransaction() throws Exception { sendMessage(_session, _destination, 5); + //sync to ensure that the above messages have reached the broker ((AMQSession) _session).sync(); restartBroker(); checkMessages(); -- cgit v1.2.1