cluster: Make sure messages are processed in-order.

diff --git a/components/cluster/endpoint.cpp b/components/cluster/endpoint.cpp
index ad74889a36a62839be45c30e342613da0b1eef9e..0bd15df35ed544333b4c38d2a6bc841bfeb211e2 100644 (file)
--- a/components/cluster/endpoint.cpp
+++ b/components/cluster/endpoint.cpp
@@ -98,7 +98,7 @@ void Endpoint::MessageThreadProc(const Stream::Ptr& stream)
                        return;
                }
 
-               Utility::QueueAsyncCallback(boost::bind(boost::ref(Endpoint::OnMessageReceived), GetSelf(), message));
+               OnMessageReceived(GetSelf(), message);
        }
 }