Skip to content

Commit 1deeae3

Browse files
committed
Add _consumerAboutToBeRecoveredAsyncWrapper to TakeOver
1 parent 5d97fa1 commit 1deeae3

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -151,10 +151,10 @@ public event AsyncEventHandler<EventArgs> ConnectionUnblockedAsync
151151

152152
public event AsyncEventHandler<RecoveringConsumerEventArgs> RecoveringConsumerAsync
153153
{
154-
add => _consumerAboutToBeRecoveredWrapper.AddHandler(value);
155-
remove => _consumerAboutToBeRecoveredWrapper.RemoveHandler(value);
154+
add => _consumerAboutToBeRecoveredAsyncWrapper.AddHandler(value);
155+
remove => _consumerAboutToBeRecoveredAsyncWrapper.RemoveHandler(value);
156156
}
157-
private AsyncEventingWrapper<RecoveringConsumerEventArgs> _consumerAboutToBeRecoveredWrapper;
157+
private AsyncEventingWrapper<RecoveringConsumerEventArgs> _consumerAboutToBeRecoveredAsyncWrapper;
158158

159159
public event AsyncEventHandler<ShutdownEventArgs> ConnectionShutdownAsync
160160
{
@@ -221,7 +221,7 @@ internal void TakeOver(Connection other)
221221
_connectionBlockedAsyncWrapper.Takeover(other._connectionBlockedAsyncWrapper);
222222
_connectionUnblockedAsyncWrapper.Takeover(other._connectionUnblockedAsyncWrapper);
223223
_connectionShutdownAsyncWrapper.Takeover(other._connectionShutdownAsyncWrapper);
224-
// TODO Why are other wrappers not taken over?
224+
_consumerAboutToBeRecoveredAsyncWrapper.Takeover(other._consumerAboutToBeRecoveredAsyncWrapper);
225225
}
226226

227227
internal async ValueTask<IConnection> OpenAsync(CancellationToken cancellationToken)

0 commit comments

Comments
 (0)