Author: gtully
Date: Wed Sep  3 07:10:18 2008
New Revision: 691619

URL: http://svn.apache.org/viewvc?rev=691619&view=rev
Log:
fix last of broken unit test after fix for AMQ-1919

Modified:
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSUsecaseTest.java
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueBrowserTest.java
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempDestLoadTest.java
    
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempQueueMemoryTest.java

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSUsecaseTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSUsecaseTest.java?rev=691619&r1=691618&r2=691619&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSUsecaseTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSUsecaseTest.java
 Wed Sep  3 07:10:18 2008
@@ -57,7 +57,7 @@
 
         // Send a message to the broker.
         connection.start();
-        Session session = connection.createSession(false, 
Session.SESSION_TRANSACTED);
+        Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
         destination = createDestination(session, destinationType);
         sendMessages(session, destination, 5);
 

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueBrowserTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueBrowserTest.java?rev=691619&r1=691618&r2=691619&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueBrowserTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsQueueBrowserTest.java
 Wed Sep  3 07:10:18 2008
@@ -43,7 +43,7 @@
      * @throws Exception
      */
     public void testReceiveBrowseReceive() throws Exception {
-        Session session = connection.createSession(false, 0);
+        Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
         ActiveMQQueue destination = new ActiveMQQueue("TEST");
         MessageProducer producer = session.createProducer(destination);
         MessageConsumer consumer = session.createConsumer(destination);

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempDestLoadTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempDestLoadTest.java?rev=691619&r1=691618&r2=691619&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempDestLoadTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempDestLoadTest.java
 Wed Sep  3 07:10:18 2008
@@ -89,7 +89,7 @@
         super.setUp();
         connection = createConnection();
         connection.start();
-        session = connection.createSession(false, 0);
+        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
 
     }
 

Modified: 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempQueueMemoryTest.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempQueueMemoryTest.java?rev=691619&r1=691618&r2=691619&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempQueueMemoryTest.java
 (original)
+++ 
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/advisory/TempQueueMemoryTest.java
 Wed Sep  3 07:10:18 2008
@@ -93,10 +93,10 @@
         super.setUp();
         serverConnection = createConnection();
         serverConnection.start();
-        serverSession = serverConnection.createSession(false, 0);
+        serverSession = serverConnection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
         clientConnection = createConnection();
         clientConnection.start();
-        clientSession = clientConnection.createSession(false, 0);
+        clientSession = clientConnection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
         serverDestination = createDestination();
     }
 


Reply via email to