Fixes to new API impl to support failover.

- client/SslConnector.cpp: throw ConnectionException for errors during connection.
- client/amqp0_10/ConnectionImpl.cpp: translate unknown exceptions to ConnectionError.
- client/amqp0_10/FailoverUpdates.cpp: interrupt receiver by closing session in dtor.


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

1 files changed, 5 insertions, 1 deletions

diff --git a/cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp b/cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp
index a1f285f5a9..2c581e9d41 100644
--- a/cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp
+++ b/cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp
@@ -211,7 +211,11 @@ void ConnectionImpl::open()
 {
     qpid::sys::AbsTime start = qpid::sys::now();
     qpid::sys::ScopedLock<qpid::sys::Semaphore> l(semaphore);
-    if (!connection.isOpen()) connect(start);
+    try {
+        if (!connection.isOpen()) connect(start);
+    }
+    catch (const types::Exception&) { throw; }
+    catch (const qpid::Exception& e) { throw messaging::ConnectionError(e.what()); }
 }
 
 bool expired(const qpid::sys::AbsTime& start, int64_t timeout)