Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix for https://issues.apache.org/activemq/browse/AMQ-2821 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@963096 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2010-07-11 16:09:02 +00:00
parent 2705e3606f
commit 70314ea8a6
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
activemq-core/src/main/java/org/apache/activemq/broker/region/policy/PolicyEntry.java
View File

@ -89,6 +89,8 @@ public class PolicyEntry extends DestinationMapEntry {
private SlowConsumerStrategy slowConsumerStrategy; private SlowConsumerStrategy slowConsumerStrategy;
private boolean prioritizedMessages; private boolean prioritizedMessages;
private boolean allConsumersExclusiveByDefault; private boolean allConsumersExclusiveByDefault;
private boolean gcInactiveDestinations;
private long inactiveTimoutBeforeGC = BaseDestination.DEFAULT_INACTIVE_TIMEOUT_BEFORE_GC;
public void configure(Broker broker,Queue queue) { public void configure(Broker broker,Queue queue) {
@ -159,6 +161,8 @@ public class PolicyEntry extends DestinationMapEntry {
} }
destination.setSlowConsumerStrategy(scs); destination.setSlowConsumerStrategy(scs);
destination.setPrioritizedMessages(isPrioritizedMessages()); destination.setPrioritizedMessages(isPrioritizedMessages());
destination.setGcIfInactive(isGcInactiveDestinations());
destination.setInactiveTimoutBeforeGC(getInactiveTimoutBeforeGC());
} }
public void configure(Broker broker, SystemUsage memoryManager, TopicSubscription subscription) { public void configure(Broker broker, SystemUsage memoryManager, TopicSubscription subscription) {
@ -761,4 +765,20 @@ public class PolicyEntry extends DestinationMapEntry {
return allConsumersExclusiveByDefault; 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;
}
} }