From 601f54f0df8ee8b5be9e25b8c7563afe9f41fb21 Mon Sep 17 00:00:00 2001 From: Gary Tully Date: Fri, 30 Sep 2011 12:21:53 +0000 Subject: [PATCH] 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 --- .../org/apache/activemq/broker/RedeliveryRestartTest.java | 6 +++--- .../failover/FailoverRedeliveryTransactionTest.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/activemq-core/src/test/java/org/apache/activemq/broker/RedeliveryRestartTest.java b/activemq-core/src/test/java/org/apache/activemq/broker/RedeliveryRestartTest.java index f25710c192..0834d38eba 100644 --- a/activemq-core/src/test/java/org/apache/activemq/broker/RedeliveryRestartTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/broker/RedeliveryRestartTest.java @@ -45,7 +45,7 @@ public class RedeliveryRestartTest extends BrokerRestartTestSupport { public void testValidateRedeliveryFlagAfterRestart() throws Exception { 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(); connection.start(); @@ -96,7 +96,7 @@ public class RedeliveryRestartTest extends BrokerRestartTestSupport { public void testValidateRedeliveryFlagAfterRecovery() throws Exception { 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(); connection.start(); @@ -122,7 +122,7 @@ public class RedeliveryRestartTest extends BrokerRestartTestSupport { broker.start(); 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.start(); diff --git a/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverRedeliveryTransactionTest.java b/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverRedeliveryTransactionTest.java index c852b593c6..248880ae15 100644 --- a/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverRedeliveryTransactionTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/transport/failover/FailoverRedeliveryTransactionTest.java @@ -32,7 +32,7 @@ public class FailoverRedeliveryTransactionTest extends FailoverTransactionTest { @Override public void configureConnectionFactory(ActiveMQConnectionFactory factory) { super.configureConnectionFactory(factory); - factory.setImmediateAck(true); + factory.setTransactedIndividualAck(true); } @Override