You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2012/08/01 20:06:37 UTC

svn commit: r1368149 - in /qpid/trunk/qpid/cpp/src/qpid/ha: BrokerReplicator.cpp ReplicatingSubscription.cpp

Author: aconway
Date: Wed Aug  1 18:06:36 2012
New Revision: 1368149

URL: http://svn.apache.org/viewvc?rev=1368149&view=rev
Log:
QPID-4176: HA Error handling

Added missing throw statements that were omitted in r1367649.

Modified:
    qpid/trunk/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp
    qpid/trunk/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp

Modified: qpid/trunk/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp?rev=1368149&r1=1368148&r2=1368149&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/BrokerReplicator.cpp Wed Aug  1 18:06:36 2012
@@ -537,6 +537,7 @@ void BrokerReplicator::doResponseHaBroke
         QPID_LOG(critical, logPrefix << "Invalid HA Broker response: " << e.what()
                  << ": " << values);
         haBroker.shutdown();
+        throw;
     }
 }
 

Modified: qpid/trunk/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp?rev=1368149&r1=1368148&r2=1368149&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/ha/ReplicatingSubscription.cpp Wed Aug  1 18:06:36 2012
@@ -230,6 +230,7 @@ ReplicatingSubscription::ReplicatingSubs
     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;
     }
 }
 



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org