You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2010/05/31 15:11:56 UTC
svn commit: r949735 -
/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java
Author: robbie
Date: Mon May 31 13:11:55 2010
New Revision: 949735
URL: http://svn.apache.org/viewvc?rev=949735&view=rev
Log:
Make PersistentStoreTest.testForcibleStartStopMidTransaction() do a syncchronous op before killing the broker to ensure all the additional messages reach the broker before it is killed. Update message numbering to be based from 1 to aid log clarity.
Modified:
qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java
Modified: qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java?rev=949735&r1=949734&r2=949735&view=diff
==============================================================================
--- qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java (original)
+++ qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/store/PersistentStoreTest.java Mon May 31 13:11:55 2010
@@ -21,6 +21,7 @@
package org.apache.qpid.server.store;
+import org.apache.qpid.client.AMQSession;
import org.apache.qpid.test.utils.QpidTestCase;
import javax.jms.Connection;
@@ -64,7 +65,7 @@ public class PersistentStoreTest extends
_session = _con.createSession(false, Session.AUTO_ACKNOWLEDGE);
_con.start();
_consumer = _session.createConsumer(_destination);
- for (int i = 0; i < NUM_MESSAGES; i++)
+ for (int i = 1; i <= NUM_MESSAGES; i++)
{
Message msg = _consumer.receive(RECEIVE_TIMEOUT);
assertNotNull("Message " + i + " not received", msg);
@@ -118,6 +119,7 @@ public class PersistentStoreTest extends
public void testForcibleStartStopMidTransaction() throws Exception
{
sendMessage(_session, _destination, 5);
+ ((AMQSession) _session).sync();
restartBroker();
checkMessages();
}
@@ -168,7 +170,7 @@ public class PersistentStoreTest extends
MessageProducer producer = session.createProducer(destination);
- for (int i = 0;i < (count); i++)
+ for (int i = 1;i <= (count); i++)
{
Message next = createNextMessage(session, i);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org