diff options
| author | Stephen D. Huston <shuston@apache.org> | 2009-10-21 20:43:46 +0000 |
|---|---|---|
| committer | Stephen D. Huston <shuston@apache.org> | 2009-10-21 20:43:46 +0000 |
| commit | 965b958161f4480a3626f5d50c3f6cc0d8517c27 (patch) | |
| tree | a8fed73e797aaf93d057bea74a9ffe91274b6792 /qpid/cpp/src/windows | |
| parent | bffa56d9e13321f8a0d2c5ef905d2847461a5f5d (diff) | |
| download | qpid-python-965b958161f4480a3626f5d50c3f6cc0d8517c27.tar.gz | |
Add missing accept() call to start listening on broker port
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@828202 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/windows')
| -rw-r--r-- | qpid/cpp/src/windows/QpiddBroker.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/qpid/cpp/src/windows/QpiddBroker.cpp b/qpid/cpp/src/windows/QpiddBroker.cpp index 5bf9477e6a..05df32397a 100644 --- a/qpid/cpp/src/windows/QpiddBroker.cpp +++ b/qpid/cpp/src/windows/QpiddBroker.cpp @@ -227,9 +227,6 @@ int QpiddBroker::execute (QpiddOptions *options) { } boost::intrusive_ptr<Broker> brokerPtr(new Broker(options->broker)); - if (options->broker.port == 0) - options->broker.port = brokerPtr->getPort(""); - std::cout << options->broker.port << std::endl; // Make sure the pid directory exists, creating if needed. LockFile // will throw an exception that makes little sense if it can't create @@ -254,6 +251,10 @@ int QpiddBroker::execute (QpiddOptions *options) { ShutdownHandler waitShut(brokerPtr); qpid::sys::Thread waitThr(waitShut); // Wait for shutdown event SetConsoleCtrlHandler((PHANDLER_ROUTINE)CtrlHandler, TRUE); + if (options->broker.port == 0) + options->broker.port = brokerPtr->getPort(""); + brokerPtr->accept(); + std::cout << options->broker.port << std::endl; brokerPtr->run(); waitShut.signal(); // In case we shut down some other way waitThr.join(); |
