From: Gunnar Beutner Date: Mon, 30 Apr 2012 10:50:11 +0000 (+0200) Subject: Bugfix for the exception handling change. X-Git-Tag: v0.0.1~566 X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=f497c5e9323d49b856bf18bd501424e598ea2962;p=icinga2 Bugfix for the exception handling change. --- diff --git a/jsonrpc/jsonrpcclient.cpp b/jsonrpc/jsonrpcclient.cpp index e7f0f4c00..30b9e5b73 100644 --- a/jsonrpc/jsonrpcclient.cpp +++ b/jsonrpc/jsonrpcclient.cpp @@ -23,12 +23,13 @@ int JsonRpcClient::DataAvailableHandler(const EventArgs& ea) try { Message message; - if (Netstring::ReadMessageFromFIFO(GetRecvQueue(), &message)) { - NewMessageEventArgs nea; - nea.Source = shared_from_this(); - nea.Message = message; - OnNewMessage(nea); - } + if (!Netstring::ReadMessageFromFIFO(GetRecvQueue(), &message)) + break; + + NewMessageEventArgs nea; + nea.Source = shared_from_this(); + nea.Message = message; + OnNewMessage(nea); } catch (const Exception& ex) { Application::Log("Exception while processing message from JSON-RPC client: " + ex.GetMessage()); Close();