From 985737b06a78b22b69be55493d1af04a5e2b16a0 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 7 Nov 2007 23:27:48 +0000 Subject: Revert r592946 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@592948 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/perftest.cpp | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) (limited to 'cpp/src') diff --git a/cpp/src/tests/perftest.cpp b/cpp/src/tests/perftest.cpp index 5d412d3837..d9316527bc 100644 --- a/cpp/src/tests/perftest.cpp +++ b/cpp/src/tests/perftest.cpp @@ -71,17 +71,15 @@ struct PublishThread : public Runnable { Thread thread; void run(); }; // Create and purge the shared queues void setup() { + cout << "Create shared queues" << endl; Connection connection; opts.open(connection); Session_0_10 session = connection.newSession(); session.setSynchronous(true); // Make sure this is all completed. session.queueDeclare(arg::queue="control"); // Control queue - if (!opts.publish) - return; // Only do this in publish thread. - if (mode==SHARED) + session.queuePurge(arg::queue="control"); + if (mode==SHARED) { session.queueDeclare(arg::queue="perftest"); // Shared data queue - if (opts.publish) { // Only do this in the publisher process. - session.queuePurge(arg::queue="control"); session.queuePurge(arg::queue="perftest"); } session.close(); -- cgit v1.2.1