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();
}