Fix crash in Endpoint::MessageThreadProc.

diff --git a/components/cluster/endpoint.cpp b/components/cluster/endpoint.cpp
index e9ab41e55cbc9da64e9c7643890107035cd55535..efb08e84711415a7e764eb144f345db25b666190 100644 (file)
--- a/components/cluster/endpoint.cpp
+++ b/components/cluster/endpoint.cpp
@@ -59,10 +59,12 @@ void Endpoint::SetClient(const Stream::Ptr& client)
                m_Client = client;
        }
 
-       boost::thread thread(boost::bind(&Endpoint::MessageThreadProc, this, client));
-       thread.detach();
+       if (client) {
+               boost::thread thread(boost::bind(&Endpoint::MessageThreadProc, this, client));
+               thread.detach();
 
-       OnConnected(GetSelf());
+               OnConnected(GetSelf());
+       }
 }
 
 void Endpoint::SendMessage(const Dictionary::Ptr& message)