Skip to content

Commit b82ae27

Browse files
committed
Rename HandleMainLoopException to HandleMainLoopExceptionAsync
1 parent 31e9ccc commit b82ae27

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

projects/RabbitMQ.Client/client/impl/Connection.Heartbeat.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ private async void HeartbeatReadTimerCallback(object? state)
108108
{
109109
var eose = new EndOfStreamException($"Heartbeat missing with heartbeat == {_heartbeat} seconds");
110110
LogCloseError(eose.Message, eose);
111-
await HandleMainLoopException(new ShutdownEventArgs(ShutdownInitiator.Library, 0, "End of stream", eose))
111+
await HandleMainLoopExceptionAsync(new ShutdownEventArgs(ShutdownInitiator.Library, 0, "End of stream", eose))
112112
.ConfigureAwait(false);
113113
shouldTerminate = true;
114114
}

projects/RabbitMQ.Client/client/impl/Connection.Receive.cs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ await ReceiveLoopAsync(mainLoopToken)
6262
Constants.InternalError,
6363
"Thread aborted (AppDomain unloaded?)",
6464
exception: taex);
65-
await HandleMainLoopException(ea)
65+
await HandleMainLoopExceptionAsync(ea)
6666
.ConfigureAwait(false);
6767
}
6868
#endif
@@ -73,7 +73,7 @@ await HandleMainLoopException(ea)
7373
0,
7474
"End of stream",
7575
exception: eose);
76-
await HandleMainLoopException(ea)
76+
await HandleMainLoopExceptionAsync(ea)
7777
.ConfigureAwait(false);
7878
}
7979
catch (HardProtocolException hpe)
@@ -91,7 +91,7 @@ await HardProtocolExceptionHandlerAsync(hpe, mainLoopToken)
9191
Constants.InternalError,
9292
fileLoadException.Message,
9393
exception: fileLoadException);
94-
await HandleMainLoopException(ea)
94+
await HandleMainLoopExceptionAsync(ea)
9595
.ConfigureAwait(false);
9696
}
9797
catch (OperationCanceledException ocex)
@@ -106,7 +106,7 @@ await HandleMainLoopException(ea)
106106
Constants.InternalError,
107107
ocex.Message,
108108
exception: ocex);
109-
await HandleMainLoopException(ea)
109+
await HandleMainLoopExceptionAsync(ea)
110110
.ConfigureAwait(false);
111111
}
112112
}
@@ -116,7 +116,7 @@ await HandleMainLoopException(ea)
116116
Constants.InternalError,
117117
ex.Message,
118118
exception: ex);
119-
await HandleMainLoopException(ea)
119+
await HandleMainLoopExceptionAsync(ea)
120120
.ConfigureAwait(false);
121121
}
122122

@@ -207,7 +207,7 @@ private void MaybeTerminateMainloopAndStopHeartbeatTimers(bool cancelMainLoop =
207207
MaybeStopHeartbeatTimers();
208208
}
209209

210-
private async Task HandleMainLoopException(ShutdownEventArgs reason)
210+
private async Task HandleMainLoopExceptionAsync(ShutdownEventArgs reason)
211211
{
212212
string message = reason.GetLogMessage();
213213
if (false == SetCloseReason(reason))

0 commit comments

Comments
 (0)