You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2010/07/11 18:09:02 UTC
svn commit: r963096 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
Author: rajdavies
Date: Sun Jul 11 16:09:02 2010
New Revision: 963096
URL: http://svn.apache.org/viewvc?rev=963096&view=rev
Log:
Fix for https://issues.apache.org/activemq/browse/AMQ-2821
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java?rev=963096&r1=963095&r2=963096&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java Sun Jul 11 16:09:02 2010
@@ -89,6 +89,8 @@ public class PolicyEntry extends Destina
private SlowConsumerStrategy slowConsumerStrategy;
private boolean prioritizedMessages;
private boolean allConsumersExclusiveByDefault;
+ private boolean gcInactiveDestinations;
+ private long inactiveTimoutBeforeGC = BaseDestination.DEFAULT_INACTIVE_TIMEOUT_BEFORE_GC;
public void configure(Broker broker,Queue queue) {
@@ -159,6 +161,8 @@ public class PolicyEntry extends Destina
}
destination.setSlowConsumerStrategy(scs);
destination.setPrioritizedMessages(isPrioritizedMessages());
+ destination.setGcIfInactive(isGcInactiveDestinations());
+ destination.setInactiveTimoutBeforeGC(getInactiveTimoutBeforeGC());
}
public void configure(Broker broker, SystemUsage memoryManager, TopicSubscription subscription) {
@@ -761,4 +765,20 @@ public class PolicyEntry extends Destina
return allConsumersExclusiveByDefault;
}
+ public boolean isGcInactiveDestinations() {
+ return this.gcInactiveDestinations;
+ }
+
+ public void setGcInactiveDestinations(boolean gcInactiveDestinations) {
+ this.gcInactiveDestinations = gcInactiveDestinations;
+ }
+
+ public long getInactiveTimoutBeforeGC() {
+ return this.inactiveTimoutBeforeGC;
+ }
+
+ public void setInactiveTimoutBeforeGC(long inactiveTimoutBeforeGC) {
+ this.inactiveTimoutBeforeGC = inactiveTimoutBeforeGC;
+ }
+
}