flywithu/CryptoExchange.Net
1
0
Fork 0
mirror of https://github.com/JKorf/CryptoExchange.Net synced 2026-02-16 14:13:46 +00:00
Code Issues Releases Wiki Activity

Added call to ApiClient.HandleUnhandledMessage when no websocket message processor is found based on topic to allow additional processing

Browse Source
This commit is contained in:
Jkorf 2026-02-10 15:59:35 +01:00
parent 3372b9eb44
commit a8ffe90bf2
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
CryptoExchange.Net/Sockets/Default/SocketConnection.cs
View File

@ -673,13 +673,16 @@ namespace CryptoExchange.Net.Sockets.Default
if (!processed)
{
lock (_listenersLock)
if (!ApiClient.HandleUnhandledMessage(this, typeIdentifier, data))
{
_logger.ReceivedMessageNotMatchedToAnyListener(
SocketId,
typeIdentifier,
topicFilter!,
string.Join(",", _listeners.Select(x => string.Join(",", x.MessageRouter.Routes.Where(x => x.TypeIdentifier == typeIdentifier).Select(x => x.TopicFilter != null ? string.Join(",", x.TopicFilter) : "[null]")))));
lock (_listenersLock)
{
_logger.ReceivedMessageNotMatchedToAnyListener(
SocketId,
typeIdentifier,
topicFilter!,
string.Join(",", _listeners.Select(x => string.Join(",", x.MessageRouter.Routes.Where(x => x.TypeIdentifier == typeIdentifier).Select(x => x.TopicFilter != null ? string.Join(",", x.TopicFilter) : "[null]")))));
}
}
}
}