From 965b958161f4480a3626f5d50c3f6cc0d8517c27 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@828202 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/windows/QpiddBroker.cpp | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'qpid/cpp/src') 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 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