diff options
| author | Alan Conway <aconway@apache.org> | 2007-06-27 00:12:26 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2007-06-27 00:12:26 +0000 |
| commit | d032f5584b0f1de890844a2796d6ba158b011fca (patch) | |
| tree | 7ffc500423a1cee3c39d2a5e27d301057fbcd0e9 /cpp/src/qpid/broker/Broker.cpp | |
| parent | 2e15ee024a7f47bda7bd6ea5991657a820bd0714 (diff) | |
| download | qpid-python-d032f5584b0f1de890844a2796d6ba158b011fca.tar.gz | |
Make check now starts a broker on a dynamically assigned port, so
multiple qpid builds on one host will not conflict.
* src/tests/run_test, start_broker, kill_broker:
Broker writes port to file, run_test sets QPID_PORT
in environment of all tests.
* src/tests/topic_publisher.cpp, topic_listener.cpp, client_test.cpp:
All test clients use TestOptions to parse options from args and env.
* src/qpid/Options.h: Renamed from CommonOptions.h
Simplified use of Options class.
* src/qpid/Url.h: Renamed defaultPort constant.
* src/tests/logging.cpp:
* src/tests/interop_runner.cpp:
* src/tests/TestOptions.h:
* src/qpidd.cpp:
* src/qpid/log/Options.cpp:
* src/qpid/log/Logger.cpp:
* src/qpid/broker/Broker.cpp:
Updated for changes to Options.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@550993 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Broker.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/Broker.cpp | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp index 01e049bdda..4354f6d38a 100644 --- a/cpp/src/qpid/broker/Broker.cpp +++ b/cpp/src/qpid/broker/Broker.cpp @@ -35,6 +35,7 @@ #include "qpid/sys/ConnectionInputHandler.h" #include "qpid/sys/ConnectionInputHandlerFactory.h" #include "qpid/sys/TimeoutHandler.h" +#include "qpid/Url.h" #include <iostream> #include <memory> @@ -44,19 +45,17 @@ using qpid::sys::Acceptor; namespace qpid { namespace broker { -Broker::Options::Options() : +Broker::Options::Options(const std::string& name) : + qpid::Options(name), + port(TcpAddress::DEFAULT_PORT), workerThreads(5), maxConnections(500), connectionBacklog(10), store(), stagingThreshold(5000000) -{} - -void Broker::Options::addTo(po::options_description& desc) { - using namespace po; - CommonOptions::addTo(desc); - desc.add_options() + addOptions() + ("port,p", optValue(port,"PORT"), "Use PORT for AMQP connections.") ("worker-threads", optValue(workerThreads, "N"), "Broker thread pool size") ("max-connections", optValue(maxConnections, "N"), @@ -114,7 +113,7 @@ Broker::shared_ptr Broker::create(const Options& config) { MessageStore* Broker::createStore(const Options& config) { if (config.store.empty()) - return new NullMessageStore(config.trace); + return new NullMessageStore(false); else return new MessageStoreModule(config.store); } @@ -141,7 +140,7 @@ Acceptor& Broker::getAcceptor() const { Acceptor::create(config.port, config.connectionBacklog, config.workerThreads, - config.trace); + false); return *acceptor; } |
