Skip to content

Commit b1239a8

Browse files
last refactoring logging
1 parent 9f4496b commit b1239a8

File tree

3 files changed

+5
-1
lines changed

3 files changed

+5
-1
lines changed

src/Ydb.Sdk/src/Services/Topic/Reader/Reader.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,8 @@ private async Task Initialize()
9696
{
9797
if (_disposeCts.IsCancellationRequested)
9898
{
99+
_logger.LogDebug("Initialize Reader[{ReaderConfig}] is stopped because it has been disposed", _config);
100+
99101
return;
100102
}
101103

src/Ydb.Sdk/src/Services/Topic/TopicSession.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ protected async void ReconnectSession()
3838
return;
3939
}
4040

41-
Logger.LogInformation("TopicSession[{SessionId}] has been deactivated, starting to reconnect", SessionId);
41+
Logger.LogDebug("TopicSession[{SessionId}] has been deactivated, starting to reconnect", SessionId);
4242

4343
await _initialize();
4444
}

src/Ydb.Sdk/src/Services/Topic/Writer/Writer.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -195,6 +195,8 @@ private async Task Initialize()
195195
{
196196
if (_isStopped)
197197
{
198+
_logger.LogDebug("Initialize Writer[{WriterConfig}] is stopped because it has been disposed", _config);
199+
198200
return;
199201
}
200202

0 commit comments

Comments
 (0)