diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2010-02-15 18:36:21 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2010-02-15 18:36:21 +0000 |
| commit | def38493b7c9ac3766d60e0cdd334bb1db7f6139 (patch) | |
| tree | 34b7ea764ad0bf24dcaffcef1c7e67a5135cba08 /cpp/src/qpid/broker/Message.cpp | |
| parent | 18ab7b99112de6c137285da1f147efbe6fca3216 (diff) | |
| download | qpid-python-def38493b7c9ac3766d60e0cdd334bb1db7f6139.tar.gz | |
Added handling for adjusting TTL on outgoing message based on how long a message has been on the queue. Added a new TTL test as ClientSessionTest.testTtl.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@910289 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Message.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/Message.cpp | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Message.cpp b/cpp/src/qpid/broker/Message.cpp index 58de0cc9dc..ff4a37c88f 100644 --- a/cpp/src/qpid/broker/Message.cpp +++ b/cpp/src/qpid/broker/Message.cpp @@ -361,6 +361,16 @@ void Message::setTimestamp(const boost::intrusive_ptr<ExpiryPolicy>& e) } } +void Message::adjustTtl() +{ + DeliveryProperties* props = getProperties<DeliveryProperties>(); + if (props->getTtl()) { + sys::Mutex::ScopedLock l(lock); + sys::Duration d(sys::AbsTime::now(), getExpiration()); + props->setTtl(int64_t(d) > 0 ? int64_t(d)/1000000 : 1); // convert from ns to ms; set to 1 if expired + } +} + void Message::setExpiryPolicy(const boost::intrusive_ptr<ExpiryPolicy>& e) { expiryPolicy = e; if (expiryPolicy) |