Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix last of broken unit test after fix for AMQ-1919 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@691619 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2008-09-03 14:10:18 +00:00
parent 1e73d70d83
commit 874e935abb
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/test/java/org/apache/activemq/JMSUsecaseTest.java
View File

@ -57,7 +57,7 @@ public class JMSUsecaseTest extends JmsTestSupport {
// Send a message to the broker. // Send a message to the broker.
connection.start(); connection.start();
Session session = connection.createSession(false, Session.SESSION_TRANSACTED); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
destination = createDestination(session, destinationType); destination = createDestination(session, destinationType);
sendMessages(session, destination, 5); sendMessages(session, destination, 5);

2
activemq-core/src/test/java/org/apache/activemq/JmsQueueBrowserTest.java
View File

@ -43,7 +43,7 @@ public class JmsQueueBrowserTest extends JmsTestSupport {
* @throws Exception * @throws Exception
*/ */
public void testReceiveBrowseReceive() 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"); ActiveMQQueue destination = new ActiveMQQueue("TEST");
MessageProducer producer = session.createProducer(destination); MessageProducer producer = session.createProducer(destination);
MessageConsumer consumer = session.createConsumer(destination); MessageConsumer consumer = session.createConsumer(destination);

2
activemq-core/src/test/java/org/apache/activemq/advisory/TempDestLoadTest.java
View File

@ -89,7 +89,7 @@ public class TempDestLoadTest extends EmbeddedBrokerTestSupport {
super.setUp(); super.setUp();
connection = createConnection(); connection = createConnection();
connection.start(); connection.start();
session = connection.createSession(false, 0); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
} }

4
activemq-core/src/test/java/org/apache/activemq/advisory/TempQueueMemoryTest.java
View File

@ -93,10 +93,10 @@ public class TempQueueMemoryTest extends EmbeddedBrokerTestSupport {
super.setUp(); super.setUp();
serverConnection = createConnection(); serverConnection = createConnection();
serverConnection.start(); serverConnection.start();
serverSession = serverConnection.createSession(false, 0); serverSession = serverConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
clientConnection = createConnection(); clientConnection = createConnection();
clientConnection.start(); clientConnection.start();
clientSession = clientConnection.createSession(false, 0); clientSession = clientConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
serverDestination = createDestination(); serverDestination = createDestination();
} }