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 2007/10/31 12:09:18 UTC
svn commit: r590623 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
Author: rajdavies
Date: Wed Oct 31 04:09:03 2007
New Revision: 590623
URL: http://svn.apache.org/viewvc?rev=590623&view=rev
Log:
updated properties
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java?rev=590623&r1=590622&r2=590623&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java Wed Oct 31 04:09:03 2007
@@ -87,9 +87,8 @@
private TaskRunnerFactory taskRunnerFactory;
private WireFormat wireFormat = new OpenWireFormat();
private SystemUsage usageManager;
- private long cleanupInterval = 1000 * 15;
- private long checkpointInterval = 1000 * 10;
- private int maxCheckpointWorkers = 1;
+ private long cleanupInterval = 1000 * 30;
+ private long checkpointInterval = 1000 * 60;
private int maxCheckpointMessageAddSize = 1024 * 4;
private AMQTransactionStore transactionStore = new AMQTransactionStore(this);
private TaskRunner checkpointTask;
@@ -682,18 +681,17 @@
return maxCheckpointMessageAddSize;
}
+ /**
+ * When set using XBean, you can use values such as: "20
+ * mb", "1024 kb", or "1 gb"
+ *
+ * @org.apache.xbean.Property propertyEditor="org.apache.activemq.util.MemoryPropertyEditor"
+ */
public void setMaxCheckpointMessageAddSize(int maxCheckpointMessageAddSize) {
this.maxCheckpointMessageAddSize = maxCheckpointMessageAddSize;
}
- public int getMaxCheckpointWorkers() {
- return maxCheckpointWorkers;
- }
-
- public void setMaxCheckpointWorkers(int maxCheckpointWorkers) {
- this.maxCheckpointWorkers = maxCheckpointWorkers;
- }
-
+
public synchronized File getDirectory() {
return directory;
}
@@ -733,10 +731,32 @@
return maxFileLength;
}
+ /**
+ * When set using XBean, you can use values such as: "20
+ * mb", "1024 kb", or "1 gb"
+ *
+ * @org.apache.xbean.Property propertyEditor="org.apache.activemq.util.MemoryPropertyEditor"
+ */
public void setMaxFileLength(int maxFileLength) {
this.maxFileLength = maxFileLength;
}
+ public long getCleanupInterval() {
+ return cleanupInterval;
+ }
+
+ public void setCleanupInterval(long cleanupInterval) {
+ this.cleanupInterval = cleanupInterval;
+ }
+
+ public long getCheckpointInterval() {
+ return checkpointInterval;
+ }
+
+ public void setCheckpointInterval(long checkpointInterval) {
+ this.checkpointInterval = checkpointInterval;
+ }
+
protected void addInProgressDataFile(AMQMessageStore store,int dataFileId) {
Set<Integer>set = dataFilesInProgress.get(store);
if (set == null) {
@@ -752,4 +772,6 @@
set.remove(dataFileId);
}
}
+
+
}