svn commit: r697100 - /incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java

[aidan]

Author: aidan
Date: Fri Sep 19 07:15:51 2008
New Revision: 697100

URL: http://svn.apache.org/viewvc?rev=697100&view=rev
Log:
QPID-1286: use transactions to make sure all messages are in there before 
starting the consumer

Modified:
    
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java

Modified: 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java?rev=697100&r1=697099&r2=697100&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/PriorityTest.java
 Fri Sep 19 07:15:51 2008
@@ -85,7 +85,7 @@
 
         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 @@
             producer.setPriority(msg % 10);
             producer.send(nextMessage(msg, false, producerSession, producer));
         }
+        producerSession.commit();
         producer.close();
         producerSession.close();
         producerConnection.close();
@@ -189,7 +190,8 @@
         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();