You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kg...@apache.org on 2011/09/07 00:08:54 UTC
svn commit: r1165900 -
/qpid/branches/qpid-3346/qpid/cpp/src/tests/qpid-send.cpp
Author: kgiusti
Date: Tue Sep 6 22:08:53 2011
New Revision: 1165900
URL: http://svn.apache.org/viewvc?rev=1165900&view=rev
Log:
QPID-3346: move timestamping after group generation code
Modified:
qpid/branches/qpid-3346/qpid/cpp/src/tests/qpid-send.cpp
Modified: qpid/branches/qpid-3346/qpid/cpp/src/tests/qpid-send.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-3346/qpid/cpp/src/tests/qpid-send.cpp?rev=1165900&r1=1165899&r2=1165900&view=diff
==============================================================================
--- qpid/branches/qpid-3346/qpid/cpp/src/tests/qpid-send.cpp (original)
+++ qpid/branches/qpid-3346/qpid/cpp/src/tests/qpid-send.cpp Tue Sep 6 22:08:53 2011
@@ -397,9 +397,6 @@ int main(int argc, char ** argv)
++sent;
if (opts.sequence)
msg.getProperties()[SN] = sent;
- if (opts.timestamp)
- msg.getProperties()[TS] = int64_t(
- qpid::sys::Duration(qpid::sys::EPOCH, qpid::sys::now()));
if (opts.flowControl) {
if ((sent % opts.flowControl) == 0) {
msg.setReplyTo(flowControlAddress);
@@ -408,10 +405,12 @@ int main(int argc, char ** argv)
else
msg.setReplyTo(Address()); // Clear the reply address.
}
-
if (groupGen.get())
groupGen->setGroupInfo(msg);
+ if (opts.timestamp)
+ msg.getProperties()[TS] = int64_t(
+ qpid::sys::Duration(qpid::sys::EPOCH, qpid::sys::now()));
sender.send(msg);
reporter.message(msg);
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org