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 2006/04/24 17:42:00 UTC
svn commit: r396583 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
Author: chirino
Date: Mon Apr 24 08:41:59 2006
New Revision: 396583
URL: http://svn.apache.org/viewcvs?rev=396583&view=rev
Log:
Don't open data files again if the store has been closed.. on windows tests were failing since the open data files could not be deleted.
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java?rev=396583&r1=396582&r2=396583&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java Mon Apr 24 08:41:59 2006
@@ -183,6 +183,8 @@
}
protected synchronized void initialize() throws IOException{
+ if( closed )
+ throw new IOException("Store has been closed.");
if(!initialized){
initialized=true;
directory=new File(name);