Don't hold up broker initialization for cluster initialization.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@896536 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 2 insertions, 9 deletions

diff --git a/cpp/src/qpid/cluster/Multicaster.cpp b/cpp/src/qpid/cluster/Multicaster.cpp
index 229d7edb1e..4a8195438f 100644
--- a/cpp/src/qpid/cluster/Multicaster.cpp
+++ b/cpp/src/qpid/cluster/Multicaster.cpp
@@ -55,15 +55,8 @@ void Multicaster::mcastBuffer(const char* data, size_t size, const ConnectionId&
 void Multicaster::mcast(const Event& e) {
     {
         sys::Mutex::ScopedLock l(lock);
-        if (!ready) {
-            if (e.isConnection()) holdingQueue.push_back(e);
-            else {
-                iovec iov = e.toIovec();
-                // FIXME aconway 2009-11-23: configurable retry --cluster-retry
-                if (!cpg.mcast(&iov, 1))
-                    throw Exception("CPG flow control error during initialization");
-                QPID_LOG(trace, "MCAST (direct) " << e);
-            }
+        if (!ready && e.isConnection()) {
+            holdingQueue.push_back(e);
             return;
         }
     }