Skip to content

Commit 57ead23

Browse files
Merge branch 'stable'
2 parents 5e07506 + d525960 commit 57ead23

File tree

1 file changed

+11
-7
lines changed

1 file changed

+11
-7
lines changed

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

Lines changed: 11 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1024,8 +1024,10 @@ public void HeartbeatReadTimerCallback(object state)
10241024
{
10251025
_heartbeatReadTimer.Change(Heartbeat * 1000, Timeout.Infinite);
10261026
}
1027-
} catch (ObjectDisposedException)
1027+
}
1028+
catch (ObjectDisposedException ignored)
10281029
{
1030+
10291031
// timer is already disposed,
10301032
// e.g. due to shutdown
10311033
}
@@ -1059,7 +1061,8 @@ public void HeartbeatWriteTimerCallback(object state)
10591061
TerminateMainloop();
10601062
FinishClose();
10611063
}
1062-
} catch (ObjectDisposedException)
1064+
}
1065+
catch (ObjectDisposedException ignored)
10631066
{
10641067
// timer is already disposed,
10651068
// e.g. due to shutdown
@@ -1068,21 +1071,22 @@ public void HeartbeatWriteTimerCallback(object state)
10681071

10691072
protected void MaybeStopHeartbeatTimers()
10701073
{
1071-
MaybeDisposeTimer(_heartbeatReadTimer);
1072-
MaybeDisposeTimer(_heartbeatWriteTimer);
1074+
MaybeDisposeTimer(ref _heartbeatReadTimer);
1075+
MaybeDisposeTimer(ref _heartbeatWriteTimer);
10731076
}
10741077

1075-
private void MaybeDisposeTimer(Timer timer)
1078+
private void MaybeDisposeTimer(ref Timer timer)
10761079
{
10771080
if (timer != null)
10781081
{
10791082
try
10801083
{
10811084
timer.Change(Timeout.Infinite, Timeout.Infinite);
10821085
timer.Dispose();
1083-
} catch (ObjectDisposedException)
1086+
}
1087+
catch (ObjectDisposedException ignored)
10841088
{
1085-
// we are shutting down, ignore
1089+
timer = null;
10861090
}
10871091
}
10881092
}

0 commit comments

Comments
 (0)