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

https://issues.apache.org/jira/browse/AMQ-3519 - allign tests with last minute attribute name change 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1177621 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2011-09-30 12:21:53 +00:00
parent 2030097e01
commit 601f54f0df
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/test/java/org/apache/activemq/broker/RedeliveryRestartTest.java
View File

@ -45,7 +45,7 @@ public class RedeliveryRestartTest extends BrokerRestartTestSupport {
public void testValidateRedeliveryFlagAfterRestart() throws Exception { public void testValidateRedeliveryFlagAfterRestart() throws Exception {
ConnectionFactory connectionFactory = ConnectionFactory connectionFactory =
new ActiveMQConnectionFactory("failover:(" + broker.getTransportConnectors().get(0).getPublishableConnectString() + ")?jms.immediateAck=true"); new ActiveMQConnectionFactory("failover:(" + broker.getTransportConnectors().get(0).getPublishableConnectString() + ")?jms.transactedIndividualAck=true");
ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection(); ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection();
connection.start(); connection.start();
@ -96,7 +96,7 @@ public class RedeliveryRestartTest extends BrokerRestartTestSupport {
public void testValidateRedeliveryFlagAfterRecovery() throws Exception { public void testValidateRedeliveryFlagAfterRecovery() throws Exception {
ConnectionFactory connectionFactory = ConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(broker.getTransportConnectors().get(0).getPublishableConnectString() + "?jms.immediateAck=true"); new ActiveMQConnectionFactory(broker.getTransportConnectors().get(0).getPublishableConnectString() + "?jms.transactedIndividualAck=true");
ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection(); ActiveMQConnection connection = (ActiveMQConnection) connectionFactory.createConnection();
connection.start(); connection.start();
@ -122,7 +122,7 @@ public class RedeliveryRestartTest extends BrokerRestartTestSupport {
broker.start(); broker.start();
connectionFactory = connectionFactory =
new ActiveMQConnectionFactory(broker.getTransportConnectors().get(0).getPublishableConnectString() + "?jms.immediateAck=true"); new ActiveMQConnectionFactory(broker.getTransportConnectors().get(0).getPublishableConnectString() + "?jms.transactedIndividualAck=true");
connection = (ActiveMQConnection) connectionFactory.createConnection(); connection = (ActiveMQConnection) connectionFactory.createConnection();
connection.start(); connection.start();

2
activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverRedeliveryTransactionTest.java
View File

@ -32,7 +32,7 @@ public class FailoverRedeliveryTransactionTest extends FailoverTransactionTest {
@Override @Override
public void configureConnectionFactory(ActiveMQConnectionFactory factory) { public void configureConnectionFactory(ActiveMQConnectionFactory factory) {
super.configureConnectionFactory(factory); super.configureConnectionFactory(factory);
factory.setImmediateAck(true); factory.setTransactedIndividualAck(true);
} }
@Override @Override