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

updated properties 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@590623 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-10-31 11:09:03 +00:00
parent b2969d05a9
commit 26387143e8
1 changed files with 33 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
activemq-core/src/main/java/org/apache/activemq/store/amq/AMQPersistenceAdapter.java
View File

@ -87,9 +87,8 @@ public class AMQPersistenceAdapter implements PersistenceAdapter, UsageListener,
private TaskRunnerFactory taskRunnerFactory; private TaskRunnerFactory taskRunnerFactory;
private WireFormat wireFormat = new OpenWireFormat(); private WireFormat wireFormat = new OpenWireFormat();
private SystemUsage usageManager; private SystemUsage usageManager;
private long cleanupInterval = 1000 * 15; private long cleanupInterval = 1000 * 30;
private long checkpointInterval = 1000 * 10; private long checkpointInterval = 1000 * 60;
private int maxCheckpointWorkers = 1;
private int maxCheckpointMessageAddSize = 1024 * 4; private int maxCheckpointMessageAddSize = 1024 * 4;
private AMQTransactionStore transactionStore = new AMQTransactionStore(this); private AMQTransactionStore transactionStore = new AMQTransactionStore(this);
private TaskRunner checkpointTask; private TaskRunner checkpointTask;
@ -682,17 +681,16 @@ public class AMQPersistenceAdapter implements PersistenceAdapter, UsageListener,
return maxCheckpointMessageAddSize; 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) { public void setMaxCheckpointMessageAddSize(int maxCheckpointMessageAddSize) {
this.maxCheckpointMessageAddSize = maxCheckpointMessageAddSize; this.maxCheckpointMessageAddSize = maxCheckpointMessageAddSize;
} }
public int getMaxCheckpointWorkers() {
return maxCheckpointWorkers;
}
public void setMaxCheckpointWorkers(int maxCheckpointWorkers) {
this.maxCheckpointWorkers = maxCheckpointWorkers;
}
public synchronized File getDirectory() { public synchronized File getDirectory() {
return directory; return directory;
@ -733,10 +731,32 @@ public class AMQPersistenceAdapter implements PersistenceAdapter, UsageListener,
return maxFileLength; 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) { public void setMaxFileLength(int maxFileLength) {
this.maxFileLength = 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) { protected void addInProgressDataFile(AMQMessageStore store,int dataFileId) {
Set<Integer>set = dataFilesInProgress.get(store); Set<Integer>set = dataFilesInProgress.get(store);
if (set == null) { if (set == null) {
@ -752,4 +772,6 @@ public class AMQPersistenceAdapter implements PersistenceAdapter, UsageListener,
set.remove(dataFileId); set.remove(dataFileId);
} }
} }
} }