activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r691619 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq: JMSUsecaseTest.java JmsQueueBrowserTest.java advisory/TempDestLoadTest.java advisory/TempQueueMemoryTest.java
Date Wed, 03 Sep 2008 14:10:18 GMT
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();
     }
 



Mime
View raw message