IlyaSobolev/DocSpace-buildtools
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Kafka: fixed onmessage error

Browse Source
This commit is contained in:
pavelbannov 2019-09-26 14:53:54 +03:00
parent 20a9d01dd4
commit 647a7fb2d4
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
common/ASC.Common/Caching/KafkaCache.cs
View File

@ -125,7 +125,14 @@ namespace ASC.Common.Caching
var cr = c.Consume(Cts[channelName].Token);
if (cr != null && cr.Value != null && !(new Guid(cr.Key.Id.ToByteArray())).Equals(Key) && Actions.TryGetValue(channelName, out var act))
{
act(cr.Value);
try
{
act(cr.Value);
}
catch (Exception e)
{
Log.Error("Kafka onmessage", e);
}
}
}
catch (ConsumeException e)