Author: rajdavies
Date: Thu Mar 13 04:35:57 2008
New Revision: 636722
URL: http://svn.apache.org/viewvc?rev=636722&view=rev
Log:
Added properties for caching of temp destinations
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
URL:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java?rev=636722&r1=636721&r2=636722&view=diff
==============================================================================
---
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
(original)
+++
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
Thu Mar 13 04:35:57 2008
@@ -167,6 +167,8 @@
private boolean monitorConnectionSplits;
private int taskRunnerPriority = Thread.NORM_PRIORITY;
private boolean dedicatedTaskRunner;
+ private boolean cacheTempDestinations=true;//useful for failover
+ private int timeBeforePurgeTempDestinations = 5000;
static {
@@ -1273,6 +1275,23 @@
public void setDedicatedTaskRunner(boolean dedicatedTaskRunner) {
this.dedicatedTaskRunner = dedicatedTaskRunner;
}
+
+ public boolean isCacheTempDestinations() {
+ return cacheTempDestinations;
+ }
+
+ public void setCacheTempDestinations(boolean cacheTempDestinations) {
+ this.cacheTempDestinations = cacheTempDestinations;
+ }
+
+ public int getTimeBeforePurgeTempDestinations() {
+ return timeBeforePurgeTempDestinations;
+ }
+
+ public void setTimeBeforePurgeTempDestinations(
+ int timeBeforePurgeTempDestinations) {
+ this.timeBeforePurgeTempDestinations = timeBeforePurgeTempDestinations;
+ }
//
// Implementation methods
//
-------------------------------------------------------------------------
