diff options
author | Alan Conway <aconway@apache.org> | 2009-03-05 13:28:14 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2009-03-05 13:28:14 +0000 |
commit | aff798ccbc13b41696c661fe07bd3934deb18625 (patch) | |
tree | ba59dbefe36754a60386f8632cb07f05e89a61ea /cpp/src/tests/failover_soak.cpp | |
parent | 23053617b74f1bbb6c8ae3c60fe24953701a4583 (diff) | |
download | qpid-python-aff798ccbc13b41696c661fe07bd3934deb18625.tar.gz |
cluster: fix delivery-property.exchange-name set on updated messages.
Logging improvements, useful for debugging:
- qpid/SessionState.cpp: show frame bodies with command IDs.
- assign cluster-wide id number to each Event.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@750456 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/failover_soak.cpp')
-rw-r--r-- | cpp/src/tests/failover_soak.cpp | 28 |
1 files changed, 13 insertions, 15 deletions
diff --git a/cpp/src/tests/failover_soak.cpp b/cpp/src/tests/failover_soak.cpp index 65c93c8e27..d84b6d58f7 100644 --- a/cpp/src/tests/failover_soak.cpp +++ b/cpp/src/tests/failover_soak.cpp @@ -339,7 +339,6 @@ wait_for_newbie ( ) { Connection connection; connection.open ( "127.0.0.1", newbie_port ); - sleep ( 2 ); connection.close(); newbie = 0; // He's no newbie anymore! return true; @@ -368,20 +367,19 @@ startNewBroker ( brokerVector & brokers, module << moduleDir << "/cluster.so"; path << srcRoot << "/qpidd"; prefix << "soak-" << brokerId; - - std::vector<std::string> argv = - list_of<string> ("qpidd") - ("--no-module-dir") - ("--load-module=cluster.so") - ("--cluster-name") - (clusterName) - ("--auth=no") - ("--no-data-dir") - ("--mgmt-enable=no") - ("--log-prefix") - (prefix.str()) - ("--log-to-file") - ("/tmp/qpidd.log"); + std::vector<std::string> argv = list_of<string> + ("qpidd") + ("--no-module-dir") + ("--load-module=cluster.so") + ("--cluster-name") + (clusterName) + ("--auth=no") + ("--no-data-dir") + ("--mgmt-enable=no") + ("--log-prefix") + (prefix.str()) + ("--log-to-file") + (prefix.str()+".log"); newbie = new ForkedBroker ( argv ); newbie_port = newbie->getPort(); |