diff --git a/CryptoExchange.Net.UnitTests/TestImplementations/TestSocketClient.cs b/CryptoExchange.Net.UnitTests/TestImplementations/TestSocketClient.cs index 27db16e..218264d 100644 --- a/CryptoExchange.Net.UnitTests/TestImplementations/TestSocketClient.cs +++ b/CryptoExchange.Net.UnitTests/TestImplementations/TestSocketClient.cs @@ -47,12 +47,12 @@ namespace CryptoExchange.Net.UnitTests.TestImplementations throw new NotImplementedException(); } - protected internal override bool MessageMatchesHandler(JToken message, object request) + protected internal override bool MessageMatchesHandler(SocketConnection s, JToken message, object request) { throw new NotImplementedException(); } - protected internal override bool MessageMatchesHandler(JToken message, string identifier) + protected internal override bool MessageMatchesHandler(SocketConnection s, JToken message, string identifier) { return true; } diff --git a/CryptoExchange.Net/Clients/BaseSocketClient.cs b/CryptoExchange.Net/Clients/BaseSocketClient.cs index 0013032..fd24d3b 100644 --- a/CryptoExchange.Net/Clients/BaseSocketClient.cs +++ b/CryptoExchange.Net/Clients/BaseSocketClient.cs @@ -567,9 +567,10 @@ namespace CryptoExchange.Net /// /// Periodically sends data over a socket connection /// + /// Identifier for the periodic send /// How often /// Method returning the object to send - public virtual void SendPeriodic(TimeSpan interval, Func objGetter) + public virtual void SendPeriodic(string identifier, TimeSpan interval, Func objGetter) { if (objGetter == null) throw new ArgumentNullException(nameof(objGetter)); @@ -595,7 +596,7 @@ namespace CryptoExchange.Net if (obj == null) continue; - log.Write(LogLevel.Trace, $"Socket {socket.Socket.Id} sending periodic"); + log.Write(LogLevel.Trace, $"Socket {socket.Socket.Id} sending periodic {identifier}"); try { @@ -603,7 +604,7 @@ namespace CryptoExchange.Net } catch (Exception ex) { - log.Write(LogLevel.Warning, $"Socket {socket.Socket.Id} Periodic send failed: " + ex); + log.Write(LogLevel.Warning, $"Socket {socket.Socket.Id} Periodic send {identifier} failed: " + ex); } } }