return;
}
- m_WriteQueue.Enqueue(boost::bind(&ApiClient::SendMessageSync, this, message));
+ m_WriteQueue.Enqueue(boost::bind(&ApiClient::SendMessageSync, static_cast<ApiClient::Ptr>(GetSelf()), message));
}
void ApiClient::SendMessageSync(const Dictionary::Ptr& message)
void ApiClient::Disconnect(void)
{
Log(LogWarning, "ApiClient", "API client disconnected for identity '" + m_Identity + "'");
- m_Stream->Close();
if (m_Endpoint)
m_Endpoint->RemoveClient(GetSelf());
ApiListener::Ptr listener = ApiListener::GetInstance();
listener->RemoveAnonymousClient(GetSelf());
}
+
+ m_Stream->Close();
}
bool ApiClient::ProcessMessage(void)