diff --git a/CryptoExchange.Net/SocketClient.cs b/CryptoExchange.Net/SocketClient.cs index b5d1248..aab39df 100644 --- a/CryptoExchange.Net/SocketClient.cs +++ b/CryptoExchange.Net/SocketClient.cs @@ -138,9 +138,16 @@ namespace CryptoExchange.Net protected virtual void ProcessMessage(SocketSubscription subscription, string data) { log.Write(LogVerbosity.Debug, $"Socket {subscription.Socket.Id} received data: " + data); - foreach (var handler in subscription.MessageHandlers) - if (handler.Value(subscription, JToken.Parse(data))) - return; + try + { + foreach (var handler in subscription.MessageHandlers) + if (handler.Value(subscription, JToken.Parse(data))) + return; + } + catch(Exception ex) + { + log.Write(LogVerbosity.Error, $"Exception during message processing: " + ex.ToString()); + } } ///