You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2007/11/08 00:27:50 UTC
svn commit: r592948 - /incubator/qpid/trunk/qpid/cpp/src/tests/perftest.cpp
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();