We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 424fb35 commit 5cc2ebaCopy full SHA for 5cc2eba
src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs
@@ -488,15 +488,13 @@ Completing task on exception...
488
_inFlightMessages.TryDequeue(out _); // Dequeue
489
}
490
491
+
492
+ Logger.LogWarning("WriterSession[{SessionId}]: stream is closed", SessionId);
493
494
catch (Driver.TransportException e)
495
{
496
Logger.LogError(e, "WriterSession[{SessionId}] have error on processing writeAck", SessionId);
497
- catch (ObjectDisposedException)
- {
498
- Logger.LogWarning("WriterSession[{SessionId}]: stream is closed", SessionId);
499
- }
500
finally
501
502
ReconnectSession();
0 commit comments