From 6ffba51e70414f0dfe3d641e7fe82622911f154a Mon Sep 17 00:00:00 2001 From: "Stephen D. Huston" Date: Wed, 21 Oct 2009 20:43:46 +0000 Subject: Add missing accept() call to start listening on broker port git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@828202 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/windows/QpiddBroker.cpp | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'cpp/src/windows/QpiddBroker.cpp') diff --git a/cpp/src/windows/QpiddBroker.cpp b/cpp/src/windows/QpiddBroker.cpp index 5bf9477e6a..05df32397a 100644 --- a/cpp/src/windows/QpiddBroker.cpp +++ b/cpp/src/windows/QpiddBroker.cpp @@ -227,9 +227,6 @@ int QpiddBroker::execute (QpiddOptions *options) { } boost::intrusive_ptr 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(); -- cgit v1.2.1