From fc97af145612ebe7b15a7e2713ddc994728aa817 Mon Sep 17 00:00:00 2001 From: Gary Tully Date: Wed, 3 Sep 2008 17:27:26 +0000 Subject: [PATCH] further adendum to https://issues.apache.org/activemq/browse/AMQ-1926 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@691692 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/kaha/impl/async/AsyncDataManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java index 9b3e326d88..fb67ac916e 100644 --- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java +++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/async/AsyncDataManager.java @@ -468,7 +468,7 @@ public class AsyncDataManager { throws IOException { accessorPool.disposeDataFileAccessors(dataFile); fileByFileMap.remove(dataFile.getFile()); - fileMap.remove(dataFile.getFile()); + fileMap.remove(dataFile.getDataFileId()); storeSize.addAndGet(-dataFile.getLength()); dataFile.unlink(); if (archiveDataLogs) {