diff options
Diffstat (limited to 'qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationRecoverer.java')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationRecoverer.java | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationRecoverer.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationRecoverer.java index f8d8ecdd7c..84f24df1cc 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationRecoverer.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/DurableConfigurationRecoverer.java @@ -27,10 +27,12 @@ import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.UUID; + import org.apache.log4j.Logger; import org.apache.qpid.server.configuration.IllegalConfigurationException; import org.apache.qpid.server.logging.EventLogger; import org.apache.qpid.server.logging.messages.ConfigStoreMessages; +import org.apache.qpid.server.logging.messages.MessageStoreMessages; import org.apache.qpid.server.logging.subjects.MessageStoreLogSubject; import static org.apache.qpid.server.model.VirtualHost.CURRENT_CONFIG_VERSION; @@ -74,6 +76,7 @@ public class DurableConfigurationRecoverer implements ConfigurationRecoveryHandl _store = store; _upgrader = _upgraderProvider.getUpgrader(configVersion, this); + _eventLogger.message(_logSubject, ConfigStoreMessages.RECOVERY_START()); } @Override |