diff --git a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java index 36189806de..2e67dec870 100644 --- a/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java +++ b/activemq-core/src/main/java/org/apache/activemq/kaha/impl/KahaStore.java @@ -183,6 +183,8 @@ public class KahaStore implements Store{ } protected synchronized void initialize() throws IOException{ + if( closed ) + throw new IOException("Store has been closed."); if(!initialized){ initialized=true; directory=new File(name);