You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2008/04/09 15:54:22 UTC
svn commit: r646352 -
/activemq/activeio/trunk/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java
Author: chirino
Date: Wed Apr 9 06:54:20 2008
New Revision: 646352
URL: http://svn.apache.org/viewvc?rev=646352&view=rev
Log:
Patch applied for AMQ-1380
Modified:
activemq/activeio/trunk/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java
Modified: activemq/activeio/trunk/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java
URL: http://svn.apache.org/viewvc/activemq/activeio/trunk/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java?rev=646352&r1=646351&r2=646352&view=diff
==============================================================================
--- activemq/activeio/trunk/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java (original)
+++ activemq/activeio/trunk/activeio-core/src/main/java/org/apache/activeio/journal/active/LogFileManager.java Wed Apr 9 06:54:20 2008
@@ -105,7 +105,8 @@
}
void initialize(int onlineLogFileCount) throws IOException {
-
+ try
+ {
LogFileNode logFiles[] = new LogFileNode[onlineLogFileCount];
// Create the log directory if it does not exist.
@@ -176,6 +177,12 @@
loadedFromCleanShutDown = false;
storeState();
+ }
+ catch (JournalLockedException e)
+ {
+ controlFile.dispose();
+ throw e;
+ }
}
private void checkAppendLog() throws IOException {