svn commit: r592948 - /incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp

[aconway]

Author: aconway
Date: Wed Nov  7 15:27:48 2007
New Revision: 592948

URL: http://svn.apache.org/viewvc?rev=592948&view=rev
Log:
Revert r592946

Modified:
    incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp

Modified: incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp?rev=592948&r1=592947&r2=592948&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp Wed Nov  7 15:27:48 
2007
@@ -71,17 +71,15 @@
 
 // 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();