svn commit: r951150 - /qpid/trunk/qpid/cpp/examples/messaging/spout.cpp

[as...@apache.org]

Author: astitcher
Date: Thu Jun  3 20:48:53 2010
New Revision: 951150

URL: http://svn.apache.org/viewvc?rev=951150&view=rev
Log:
Remove dependency on qpid::sys::AbsTime (which uses boost on Windows)

Modified:
    qpid/trunk/qpid/cpp/examples/messaging/spout.cpp

Modified: qpid/trunk/qpid/cpp/examples/messaging/spout.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/examples/messaging/spout.cpp?rev=951150&r1=951149&r2=951150&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/examples/messaging/spout.cpp (original)
+++ qpid/trunk/qpid/cpp/examples/messaging/spout.cpp Thu Jun  3 20:48:53 2010
@@ -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;



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org