Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@669519 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2008-06-19 15:59:53 +00:00
parent 1555260c6c
commit 1acfd0d607
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java
View File

@ -268,6 +268,8 @@ public class AsyncDataManager {
String fileName = filePrefix + nextNum; String fileName = filePrefix + nextNum;
File file = new File(directory, fileName); File file = new File(directory, fileName);
DataFile nextWriteFile = new DataFile(file, nextNum, preferedFileLength); DataFile nextWriteFile = new DataFile(file, nextNum, preferedFileLength);
//actually allocate the disk space
nextWriteFile.closeRandomAccessFile(nextWriteFile.openRandomAccessFile(true));
fileMap.put(nextWriteFile.getDataFileId(), nextWriteFile); fileMap.put(nextWriteFile.getDataFileId(), nextWriteFile);
fileByFileMap.put(file, nextWriteFile); fileByFileMap.put(file, nextWriteFile);
if (currentWriteFile != null) { if (currentWriteFile != null) {