This commit is contained in:
gtully 2014-03-11 12:36:33 +00:00
parent 87420cc455
commit a3a41dae37
1 changed files with 2 additions and 1 deletions

View File

@ -40,7 +40,7 @@ public class BrokerRedeliveryTest extends org.apache.activemq.TestSupport {
final ActiveMQQueue destination = new ActiveMQQueue("Redelivery"); final ActiveMQQueue destination = new ActiveMQQueue("Redelivery");
final String data = "hi"; final String data = "hi";
final long redeliveryDelayMillis = 2000; final long redeliveryDelayMillis = 2000;
final long initialRedeliveryDelayMillis = 4000; long initialRedeliveryDelayMillis = 4000;
int maxBrokerRedeliveries = 2; int maxBrokerRedeliveries = 2;
public void testScheduledRedelivery() throws Exception { public void testScheduledRedelivery() throws Exception {
@ -48,6 +48,7 @@ public class BrokerRedeliveryTest extends org.apache.activemq.TestSupport {
} }
public void testInfiniteRedelivery() throws Exception { public void testInfiniteRedelivery() throws Exception {
initialRedeliveryDelayMillis = redeliveryDelayMillis;
maxBrokerRedeliveries = RedeliveryPolicy.NO_MAXIMUM_REDELIVERIES; maxBrokerRedeliveries = RedeliveryPolicy.NO_MAXIMUM_REDELIVERIES;
doTestScheduledRedelivery(RedeliveryPolicy.DEFAULT_MAXIMUM_REDELIVERIES + 1, false); doTestScheduledRedelivery(RedeliveryPolicy.DEFAULT_MAXIMUM_REDELIVERIES + 1, false);
} }