fix for failing test

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@513759 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-03-02 13:44:16 +00:00
parent 4089d75fb7
commit deaeab06e2
1 changed files with 2 additions and 1 deletions

View File

@ -19,6 +19,7 @@ package org.apache.activemq.broker.policy;
import org.apache.activemq.broker.QueueSubscriptionTest; import org.apache.activemq.broker.QueueSubscriptionTest;
import org.apache.activemq.broker.BrokerService; import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.region.policy.FixedCountSubscriptionRecoveryPolicy;
import org.apache.activemq.broker.region.policy.PolicyEntry; import org.apache.activemq.broker.region.policy.PolicyEntry;
import org.apache.activemq.broker.region.policy.PolicyMap; import org.apache.activemq.broker.region.policy.PolicyMap;
import org.apache.activemq.broker.region.policy.SimpleDispatchPolicy; import org.apache.activemq.broker.region.policy.SimpleDispatchPolicy;
@ -34,7 +35,7 @@ public class SimpleDispatchPolicyTest extends QueueSubscriptionTest {
PolicyEntry policy = new PolicyEntry(); PolicyEntry policy = new PolicyEntry();
policy.setDispatchPolicy(new SimpleDispatchPolicy()); policy.setDispatchPolicy(new SimpleDispatchPolicy());
policy.setSubscriptionRecoveryPolicy(new FixedCountSubscriptionRecoveryPolicy());
PolicyMap pMap = new PolicyMap(); PolicyMap pMap = new PolicyMap();
pMap.setDefaultEntry(policy); pMap.setDefaultEntry(policy);