svn commit: r513761 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java

[rajdavies]

Author: rajdavies
Date: Fri Mar  2 05:47:39 2007
New Revision: 513761

URL: http://svn.apache.org/viewvc?view=rev&rev=513761
Log:
set default recovery policy (can't be FixedCountSubscriptionRecoveryPolicy) - 
as that
can hog alot of memory if large messages are used

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java?view=diff&rev=513761&r1=513760&r2=513761
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/Topic.java
 Fri Mar  2 05:47:39 2007
@@ -26,7 +26,7 @@
 import org.apache.activemq.broker.ConnectionContext;
 import org.apache.activemq.broker.region.policy.DeadLetterStrategy;
 import org.apache.activemq.broker.region.policy.DispatchPolicy;
-import org.apache.activemq.broker.region.policy.NoSubscriptionRecoveryPolicy;
+import 
org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy;
 import org.apache.activemq.broker.region.policy.SharedDeadLetterStrategy;
 import org.apache.activemq.broker.region.policy.SimpleDispatchPolicy;
 import org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy;
@@ -64,7 +64,7 @@
     protected final DestinationStatistics destinationStatistics = new 
DestinationStatistics();
 
     private DispatchPolicy dispatchPolicy = new SimpleDispatchPolicy();
-    private SubscriptionRecoveryPolicy subscriptionRecoveryPolicy = new 
NoSubscriptionRecoveryPolicy();
+    private SubscriptionRecoveryPolicy subscriptionRecoveryPolicy = new 
FixedSizedSubscriptionRecoveryPolicy();
     private boolean sendAdvisoryIfNoConsumers;
     private DeadLetterStrategy deadLetterStrategy = new 
SharedDeadLetterStrategy();
     private final ConcurrentHashMap durableSubcribers = new 
ConcurrentHashMap();