Author: shuston
Date: Wed Oct 21 20:43:46 2009
New Revision: 828202
URL: http://svn.apache.org/viewvc?rev=828202&view=rev
Log:
Add missing accept() call to start listening on broker port
Modified:
qpid/trunk/qpid/cpp/src/windows/QpiddBroker.cpp
Modified: qpid/trunk/qpid/cpp/src/windows/QpiddBroker.cpp
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/windows/QpiddBroker.cpp?rev=828202&r1=828201&r2=828202&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/windows/QpiddBroker.cpp (original)
+++ qpid/trunk/qpid/cpp/src/windows/QpiddBroker.cpp Wed Oct 21 20:43:46 2009
@@ -227,9 +227,6 @@
}
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 @@
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();
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
