summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-03-03 17:06:44 +0000
committerGordon Sim <gsim@apache.org>2010-03-03 17:06:44 +0000
commit2a71aa199010c48608f6d63794f52ad2e7afede5 (patch)
treec75a9248e0ced59974bde18a73f5237f5efb8446 /cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp
parent589def015a6567ecb7be9fe2af0ebec662cea56c (diff)
downloadqpid-python-2a71aa199010c48608f6d63794f52ad2e7afede5.tar.gz
QPID-2402 & QPID-2406: Documented the units for the ttl property of Message. Eliminated use of qpid::sys::Duration from API.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@918575 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp')
-rw-r--r--cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp
index 1f5c3162e5..e24f2ba5b4 100644
--- a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp
+++ b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp
@@ -40,28 +40,28 @@ void ReceiverImpl::received(qpid::messaging::Message&)
}
}
-qpid::messaging::Message ReceiverImpl::get(qpid::sys::Duration timeout)
+qpid::messaging::Message ReceiverImpl::get(qpid::messaging::Duration timeout)
{
qpid::messaging::Message result;
if (!get(result, timeout)) throw Receiver::NoMessageAvailable();
return result;
}
-qpid::messaging::Message ReceiverImpl::fetch(qpid::sys::Duration timeout)
+qpid::messaging::Message ReceiverImpl::fetch(qpid::messaging::Duration timeout)
{
qpid::messaging::Message result;
if (!fetch(result, timeout)) throw Receiver::NoMessageAvailable();
return result;
}
-bool ReceiverImpl::get(qpid::messaging::Message& message, qpid::sys::Duration timeout)
+bool ReceiverImpl::get(qpid::messaging::Message& message, qpid::messaging::Duration timeout)
{
Get f(*this, message, timeout);
while (!parent.execute(f)) {}
return f.result;
}
-bool ReceiverImpl::fetch(qpid::messaging::Message& message, qpid::sys::Duration timeout)
+bool ReceiverImpl::fetch(qpid::messaging::Message& message, qpid::messaging::Duration timeout)
{
Fetch f(*this, message, timeout);
while (!parent.execute(f)) {}
@@ -143,12 +143,12 @@ ReceiverImpl::ReceiverImpl(SessionImpl& p, const std::string& name,
parent(p), destination(name), address(a), byteCredit(0xFFFFFFFF),
state(UNRESOLVED), capacity(0), window(0) {}
-bool ReceiverImpl::getImpl(qpid::messaging::Message& message, qpid::sys::Duration timeout)
+bool ReceiverImpl::getImpl(qpid::messaging::Message& message, qpid::messaging::Duration timeout)
{
return parent.get(*this, message, timeout);
}
-bool ReceiverImpl::fetchImpl(qpid::messaging::Message& message, qpid::sys::Duration timeout)
+bool ReceiverImpl::fetchImpl(qpid::messaging::Message& message, qpid::messaging::Duration timeout)
{
if (state == CANCELLED) return false;//TODO: or should this be an error?