diff options
| author | Gordon Sim <gsim@apache.org> | 2010-03-03 17:06:44 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2010-03-03 17:06:44 +0000 |
| commit | 2a71aa199010c48608f6d63794f52ad2e7afede5 (patch) | |
| tree | c75a9248e0ced59974bde18a73f5237f5efb8446 /cpp/src/qpid/client/amqp0_10/ReceiverImpl.cpp | |
| parent | 589def015a6567ecb7be9fe2af0ebec662cea56c (diff) | |
| download | qpid-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.cpp | 12 |
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? |
