QPID-1286: use transactions to make sure all messages are in there before starting the consumer

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@697100 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 2 deletions

diff --git a/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java b/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java
index 3a4e6a62f8..bb386f9f6f 100644
--- a/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java
@@ -85,7 +85,7 @@ public class PriorityTest extends TestCase
 
         context = factory.getInitialContext(env);
         producerConnection = ((ConnectionFactory) context.lookup("connection")).createConnection();
-        producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        producerSession = producerConnection.createSession(true, Session.AUTO_ACKNOWLEDGE);
 
         producerConnection.start();
         
@@ -124,6 +124,7 @@ public class PriorityTest extends TestCase
             producer.setPriority(msg % 10);
             producer.send(nextMessage(msg, false, producerSession, producer));
         }
+        producerSession.commit();
         producer.close();
         producerSession.close();
         producerConnection.close();
@@ -189,7 +190,8 @@ public class PriorityTest extends TestCase
         producer.send(nextMessage(11, false, producerSession, producer));
         producer.setPriority(9);
         producer.send(nextMessage(12, false, producerSession, producer));
-
+        producerSession.commit();
+        
         consumer = consumerSession.createConsumer(queue);
         consumerConnection.start();