summaryrefslogtreecommitdiff
path: root/qpid/cpp/examples/messaging
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2010-06-03 20:48:53 +0000
committerAndrew Stitcher <astitcher@apache.org>2010-06-03 20:48:53 +0000
commit881e22ac08bbb8c8ed6035f7f3abf47b21da48f3 (patch)
treec1fbb54a3cbe6605271e59c42ef3e921964f049a /qpid/cpp/examples/messaging
parent095fb80c67258ab00a2654bdd4a094f4d37ed4b8 (diff)
downloadqpid-python-881e22ac08bbb8c8ed6035f7f3abf47b21da48f3.tar.gz
Remove dependency on qpid::sys::AbsTime (which uses boost on Windows)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@951150 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/examples/messaging')
-rw-r--r--qpid/cpp/examples/messaging/spout.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/qpid/cpp/examples/messaging/spout.cpp b/qpid/cpp/examples/messaging/spout.cpp
index 05d66f60e6..e100560739 100644
--- a/qpid/cpp/examples/messaging/spout.cpp
+++ b/qpid/cpp/examples/messaging/spout.cpp
@@ -25,19 +25,16 @@
#include <qpid/messaging/Sender.h>
#include <qpid/messaging/Session.h>
#include <qpid/types/Variant.h>
-#include <qpid/sys/Time.h>
#include <iostream>
#include <sstream>
#include <vector>
+#include <ctime>
#include "OptionParser.h"
using namespace qpid::messaging;
using namespace qpid::types;
-using qpid::sys::AbsTime;
-using qpid::sys::now;
-using qpid::sys::TIME_INFINITE;
typedef std::vector<std::string> string_vector;
@@ -152,8 +149,11 @@ int main(int argc, char** argv)
message.setContent(options.content);
message.setContentType("text/plain");
}
- AbsTime end(now(), options.timeout * qpid::sys::TIME_SEC);
- for (int count = 0; (count < options.count || options.count == 0) && (options.timeout == 0 || end > now()); count++) {
+ std::time_t start = std::time(0);
+ for (int count = 0;
+ (count < options.count || options.count == 0) &&
+ (options.timeout == 0 || std::difftime(std::time(0), start) < options.timeout);
+ count++) {
if (!options.replyto.empty()) message.setReplyTo(Address(options.replyto));
std::string id = options.id.empty() ? Uuid(true).str() : options.id;
std::stringstream spoutid;