From 350d72e7de9b9840894ca921fb94b3f6462e88a6 Mon Sep 17 00:00:00 2001 From: Kenneth Anthony Giusti Date: Wed, 9 Nov 2011 18:46:57 +0000 Subject: add timestamp of oldest msg per group to query output git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1199914 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/qpid/broker/MessageGroupManager.cpp | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp b/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp index 00d1a58bef..3a996db9cc 100644 --- a/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp +++ b/qpid/cpp/src/qpid/broker/MessageGroupManager.cpp @@ -281,7 +281,16 @@ void MessageGroupManager::query(qpid::types::Variant::Map& status) const qpid::types::Variant::Map info; info[GROUP_ID_KEY] = g->first; info[GROUP_MSG_COUNT] = g->second.members.size(); - info[GROUP_TIMESTAMP] = 0; /** @todo KAG - NEED HEAD MSG TIMESTAMP */ + // set the timestamp to the arrival timestamp of the oldest (HEAD) message, if present + info[GROUP_TIMESTAMP] = 0; + if (g->second.members.size() != 0) { + QueuedMessage qm; + if (messages.find(g->second.members.front(), qm) && + qm.payload && + qm.payload->hasProperties()) { + info[GROUP_TIMESTAMP] = qm.payload->getProperties()->getTimestamp(); + } + } info[GROUP_CONSUMER] = g->second.owner; groups.push_back(info); } -- cgit v1.2.1