From b1f0c45b454f0161ac85c09551996fc38e97a525 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Mon, 1 Oct 2007 20:13:45 +0000 Subject: - add option to create durable messages. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@581057 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/perftest.cpp | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) (limited to 'cpp/src') diff --git a/cpp/src/tests/perftest.cpp b/cpp/src/tests/perftest.cpp index 9d5ea593fe..3b6859eff9 100644 --- a/cpp/src/tests/perftest.cpp +++ b/cpp/src/tests/perftest.cpp @@ -26,6 +26,7 @@ #include "qpid/client/Queue.h" #include "qpid/client/Connection.h" #include "qpid/client/MessageListener.h" +#include #include "qpid/QpidError.h" #include "qpid/sys/Monitor.h" #include "qpid/sys/Time.h" @@ -47,12 +48,14 @@ struct Opts : public TestOptions { bool listen; bool publish; int count; + bool durable; Opts() : listen(false), publish(false), count(500000) { addOptions() ("listen", optValue(listen), "Consume messages.") ("publish", optValue(publish), "Produce messages.") - ("count", optValue(count, "N"), "Messages to send/receive."); + ("count", optValue(count, "N"), "Messages to send/receive.") + ("durable", optValue(durable, "N"), "Publish messages as durable."); } }; @@ -195,6 +198,10 @@ void PublishThread::run() { if (::clock_gettime(CLOCK_REALTIME, &startTime)) throw Exception(QPID_MSG("clock_gettime failed: " << strError(errno))); + bool durable = opts.durable; + if (durable) + msg.getDeliveryProperties().setDeliveryMode(framing::PERSISTENT); + for (int i=0; i