You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2009/10/28 16:38:45 UTC
svn commit: r830623 -
/qpid/branches/0.5.x-dev/qpid/cpp/src/windows/QpiddBroker.cpp
Author: ritchiem
Date: Wed Oct 28 15:38:44 2009
New Revision: 830623
URL: http://svn.apache.org/viewvc?rev=830623&view=rev
Log:
Add missing accept() call to start listening on broker port
Modified:
qpid/branches/0.5.x-dev/qpid/cpp/src/windows/QpiddBroker.cpp
Modified: qpid/branches/0.5.x-dev/qpid/cpp/src/windows/QpiddBroker.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/0.5.x-dev/qpid/cpp/src/windows/QpiddBroker.cpp?rev=830623&r1=830622&r2=830623&view=diff
==============================================================================
--- qpid/branches/0.5.x-dev/qpid/cpp/src/windows/QpiddBroker.cpp (original)
+++ qpid/branches/0.5.x-dev/qpid/cpp/src/windows/QpiddBroker.cpp Wed Oct 28 15:38:44 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:commits-subscribe@qpid.apache.org