diff options
Diffstat (limited to 'cpp/src/qmf/ResilientConnection.cpp')
| -rw-r--r-- | cpp/src/qmf/ResilientConnection.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/cpp/src/qmf/ResilientConnection.cpp b/cpp/src/qmf/ResilientConnection.cpp index 7ebd0a47c1..3a32d11df4 100644 --- a/cpp/src/qmf/ResilientConnection.cpp +++ b/cpp/src/qmf/ResilientConnection.cpp @@ -27,6 +27,7 @@ #include <qpid/sys/Runnable.h> #include <qpid/sys/Mutex.h> #include <qpid/sys/Condition.h> +#include <qpid/sys/Time.h> #include <qpid/log/Statement.h> #include <qpid/RefCounted.h> #include <boost/bind.hpp> @@ -144,7 +145,7 @@ void RCSession::run() { try { subscriptions->run(); - } catch (exception& e) { + } catch (exception& /*e*/) { connImpl.sessionClosed(this); } } @@ -350,7 +351,7 @@ void ResilientConnectionImpl::run() delay *= delayFactor; } - ::sleep(delay); + ::qpid::sys::sleep(delay); } } @@ -373,7 +374,7 @@ void ResilientConnectionImpl::sessionClosed(RCSession*) void ResilientConnectionImpl::EnqueueEvent(ResilientConnectionEvent::EventKind kind, void* sessionContext, - const MessageImpl& message, + const qmf::MessageImpl& message, const string& errorText) { Mutex::ScopedLock _lock(lock); |