summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Broker.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-06-27 00:12:26 +0000
committerAlan Conway <aconway@apache.org>2007-06-27 00:12:26 +0000
commitd032f5584b0f1de890844a2796d6ba158b011fca (patch)
tree7ffc500423a1cee3c39d2a5e27d301057fbcd0e9 /cpp/src/qpid/broker/Broker.cpp
parent2e15ee024a7f47bda7bd6ea5991657a820bd0714 (diff)
downloadqpid-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.cpp17
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;
}