diff options
| author | Keith Wall <kwall@apache.org> | 2014-09-23 06:54:51 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2014-09-23 06:54:51 +0000 |
| commit | 390970ba44fbb63762ce40358233b616eb59ecd9 (patch) | |
| tree | def4731d8f720c7de2df91b3013c232c4aa53cec /qpid/java/bdbstore/src | |
| parent | be5d2b435764a3a336138b5045964c92f552e86b (diff) | |
| download | qpid-python-390970ba44fbb63762ce40358233b616eb59ecd9.tar.gz | |
QPID-6102: [Java Broker] HA Prevent InsufficientReplica/InsufficientAckExceptions and other exceptions that require JE environment restart from causing Broker shutdown.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1626953 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/bdbstore/src')
| -rw-r--r-- | qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java | 2 |
1 files changed, 2 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 4cd677586a..fa417981c7 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 @@ -90,6 +90,7 @@ import org.apache.qpid.server.store.berkeleydb.CoalescingCommiter; import org.apache.qpid.server.store.berkeleydb.EnvHomeRegistry; import org.apache.qpid.server.store.berkeleydb.EnvironmentFacade; import org.apache.qpid.server.store.berkeleydb.LoggingAsyncExceptionListener; +import org.apache.qpid.server.util.ConnectionScopedRuntimeException; import org.apache.qpid.server.util.DaemonThreadFactory; public class ReplicatedEnvironmentFacade implements EnvironmentFacade, StateChangeListener @@ -384,6 +385,7 @@ public class ReplicatedEnvironmentFacade implements EnvironmentFacade, StateChan if (restart) { tryToRestartEnvironment(dbe); + throw new ConnectionScopedRuntimeException(noMajority ? "Required number of nodes not reachable" : "Underlying JE environment is being restarted", dbe); } return dbe; } |