summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/SubscriptionManager.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-10-31 15:08:00 +0000
committerAlan Conway <aconway@apache.org>2008-10-31 15:08:00 +0000
commit79323867dae1ad7b0d00e4055e506749236d9bf1 (patch)
tree7a072a6ad8f9b81cf5984a61d2e9cdfbb26d1d89 /cpp/src/qpid/client/SubscriptionManager.cpp
parent2ff919b2bf8623b6bf542e589aae4c05c403a009 (diff)
downloadqpid-python-79323867dae1ad7b0d00e4055e506749236d9bf1.tar.gz
Added return Message overload of SubscriptionManager get().
Fixed compile error in broker/Vhost.cpp git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@709440 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/SubscriptionManager.cpp')
-rw-r--r--cpp/src/qpid/client/SubscriptionManager.cpp7
1 files changed, 7 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/SubscriptionManager.cpp b/cpp/src/qpid/client/SubscriptionManager.cpp
index 350fd86aa6..6fa1973b9d 100644
--- a/cpp/src/qpid/client/SubscriptionManager.cpp
+++ b/cpp/src/qpid/client/SubscriptionManager.cpp
@@ -107,6 +107,13 @@ bool SubscriptionManager::get(Message& result, const std::string& queue, sys::Du
return lq.get(result, 0);
}
+Message SubscriptionManager::get(const std::string& queue, sys::Duration timeout) {
+ Message result;
+ if (!get(result, queue, timeout))
+ throw Exception("Timed out waiting for a message");
+ return result;
+}
+
Session SubscriptionManager::getSession() const { return session; }
Subscription SubscriptionManager::getSubscription(const std::string& name) const {