Handle exceptions on message reception

This commit is contained in:
badaix 2022-09-09 15:10:42 +02:00
parent e32eaa87af
commit 0da026a289

View file

@ -116,10 +116,19 @@ void StreamServer::onChunkEncoded(const PcmStream* pcmStream, bool isDefaultStre
void StreamServer::onMessageReceived(StreamSession* streamSession, const msg::BaseMessage& baseMessage, char* buffer) void StreamServer::onMessageReceived(StreamSession* streamSession, const msg::BaseMessage& baseMessage, char* buffer)
{
try
{ {
if (messageReceiver_ != nullptr) if (messageReceiver_ != nullptr)
messageReceiver_->onMessageReceived(streamSession, baseMessage, buffer); messageReceiver_->onMessageReceived(streamSession, baseMessage, buffer);
} }
catch (const std::exception& e)
{
LOG(ERROR, LOG_TAG) << "Server::onMessageReceived exception: " << e.what() << ", message type: " << baseMessage.type << "\n";
auto session = getStreamSession(streamSession);
session->stop();
}
}
void StreamServer::onDisconnect(StreamSession* streamSession) void StreamServer::onDisconnect(StreamSession* streamSession)