diff options
Diffstat (limited to 'qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java')
-rw-r--r-- | qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java index 722a0bca31..253c68bfb7 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java @@ -346,6 +346,14 @@ public class ReplicatedEnvironmentFacade implements EnvironmentFacade, StateChan } }); } + else + { + if (LOGGER.isDebugEnabled()) + { + LOGGER.debug("Ignoring the state environment change event as the environment facade for node '" + _prettyGroupNodeName + + "' is in state " + _state.get()); + } + } } private void stateChanged(StateChangeEvent stateChangeEvent) @@ -931,6 +939,10 @@ public class ReplicatedEnvironmentFacade implements EnvironmentFacade, StateChan restore.execute(ile, config); environment = new ReplicatedEnvironment(environmentPathFile, replicationConfig, envConfig); } + if (LOGGER.isInfoEnabled()) + { + LOGGER.info("Environment is created for node " + _prettyGroupNodeName); + } return environment; } |