mirror of https://github.com/apache/activemq.git
https://issues.apache.org/jira/browse/AMQ-3490 - defer setting init done flag till complete, ensure a failed init attempt is retried
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1171487 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
94de98a64c
commit
4a697f852a
|
@ -266,7 +266,6 @@ public class PListStore extends ServiceSupport implements BrokerServiceAware, Ru
|
|||
protected synchronized void intialize() throws Exception {
|
||||
if (isStarted()) {
|
||||
if (this.initialized == false) {
|
||||
this.initialized = true;
|
||||
if (this.directory == null) {
|
||||
this.directory = new File(IOHelper.getDefaultDataDirectory() + File.pathSeparator + "delayedDB");
|
||||
}
|
||||
|
@ -312,6 +311,7 @@ public class PListStore extends ServiceSupport implements BrokerServiceAware, Ru
|
|||
}
|
||||
scheduler.executePeriodically(this, cleanupInterval);
|
||||
}
|
||||
this.initialized = true;
|
||||
LOG.info(this + " initialized");
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue