QPID-4176: HA Error handling

Added missing throw statements that were omitted in r1367649.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1368149 13f79535-47bb-0310-9956-ffa450edef68

2 files changed, 3 insertions, 0 deletions

diff --git a/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp b/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp
index 6a17555b6f..c8c4a42d72 100644
--- a/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp
+++ b/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp
@@ -537,6 +537,7 @@ void BrokerReplicator::doResponseHaBroker(Variant::Map& values) {
         QPID_LOG(critical, logPrefix << "Invalid HA Broker response: " << e.what()
                  << ": " << values);
         haBroker.shutdown();
+        throw;
     }
 }
 
diff --git a/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp b/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp
index 381744b271..c960758eaf 100644
--- a/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp
+++ b/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp
@@ -230,6 +230,7 @@ ReplicatingSubscription::ReplicatingSubscription(
     catch (const std::exception& e) {
         QPID_LOG(error, logPrefix << "Creation error: " << e.what()
                  << ": arguments=" << getArguments());
+        throw;
     }
 }
 
@@ -254,6 +255,7 @@ void ReplicatingSubscription::initialize() {
     catch (const std::exception& e) {
         QPID_LOG(error, logPrefix << "Initialization error: " << e.what()
                  << ": arguments=" << getArguments());
+        throw;
     }
 }