Skip to content

Commit 78a1ec6

Browse files
authored
Make receiver concurrency lock object private and non static (#1539)
1 parent 78d195f commit 78a1ec6

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/NServiceBus.Transport.Sql.Shared/Receiving/MessageReceiver.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -261,6 +261,7 @@ await messageProcessingCircuitBreaker.Failure(ex, messageProcessingCancellationT
261261

262262
protected TableBasedQueue inputQueue;
263263
TableBasedQueue errorQueue;
264+
readonly object lockObject = new();
264265
readonly TransportDefinition transport;
265266
readonly string errorQueueAddress;
266267
readonly Action<string, Exception, CancellationToken> criticalErrorAction;
@@ -287,7 +288,5 @@ await messageProcessingCircuitBreaker.Failure(ex, messageProcessingCancellationT
287288
public ISubscriptionManager Subscriptions { get; }
288289
public string Id { get; }
289290
public string ReceiveAddress { get; }
290-
291-
public static object lockObject = new();
292291
}
293292
}

0 commit comments

Comments
 (0)