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

Implements AMQ-5072: Support configuring a different directory for the KahaDB index files.

This commit is contained in:
Hiram Chirino 2014-02-21 11:08:27 -05:00
parent 546714550f
commit 232b8c51e9
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
activemq-kahadb-store/src/main/java/org/apache/activemq/store/kahadb/MessageDatabase.java
View File

@ -224,6 +224,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
protected boolean deleteAllMessages;
protected File directory = DEFAULT_DIRECTORY;
protected File indexDirectory = null;
protected Thread checkpointThread;
protected boolean enableJournalDiskSyncs=true;
protected boolean archiveDataLogs;
@ -2385,8 +2386,12 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
// Initialization related implementation methods.
// /////////////////////////////////////////////////////////////////
private PageFile createPageFile() {
PageFile index = new PageFile(directory, "db");
private PageFile createPageFile() throws IOException {
if( indexDirectory == null ) {
indexDirectory = directory;
}
IOHelper.mkdirs(indexDirectory);
PageFile index = new PageFile(indexDirectory, "db");
index.setEnableWriteThread(isEnableIndexWriteAsync());
index.setWriteBatchSize(getIndexWriteBatchSize());
index.setPageCacheSize(indexCacheSize);
@ -2503,7 +2508,7 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
return this.metadata.producerSequenceIdTracker.getAuditDepth();
}
public PageFile getPageFile() {
public PageFile getPageFile() throws IOException {
if (pageFile == null) {
pageFile = createPageFile();
}
@ -3057,4 +3062,12 @@ public abstract class MessageDatabase extends ServiceSupport implements BrokerSe
}
}
}
public File getIndexDirectory() {
return indexDirectory;
}
public void setIndexDirectory(File indexDirectory) {
this.indexDirectory = indexDirectory;
}
}