Allow message locks to complete until the receive endpoint has been stopped (Azure Service Bus).

Author: phatboyg

src/Transports/MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/Receiver.cs

@@ -113,7 +113,7 @@ async Task OnMessage(ProcessMessageEventArgs messageReceiver, ServiceBusReceived
             if (IsStopping)
                 return;
 
-            MessageLockContext lockContext = new ServiceBusMessageLockContext(messageReceiver, message, cancellationToken);
+            MessageLockContext lockContext = new ServiceBusMessageLockContext(messageReceiver, message, Stopped);
             var context = new ServiceBusReceiveContext(message, _context, cancellationToken, lockContext, _clientContext);
 
             CancellationTokenSource cancellationTokenSource = null;

src/Transports/MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/SessionReceiver.cs

@@ -31,8 +31,8 @@ async Task OnSession(ProcessSessionMessageEventArgs messageSession, ServiceBusRe
             if (IsStopping)
                 return;
 
-            MessageLockContext lockContext = new ServiceBusSessionMessageLockContext(messageSession, message, cancellationToken);
-            MessageSessionContext sessionContext = new ServiceBusMessageSessionContext(messageSession, cancellationToken);
+            MessageLockContext lockContext = new ServiceBusSessionMessageLockContext(messageSession, message, Stopped);
+            MessageSessionContext sessionContext = new ServiceBusMessageSessionContext(messageSession, Stopped);
             var context = new ServiceBusReceiveContext(message, _context, lockContext, _clientContext, sessionContext);
 
             CancellationTokenSource cancellationTokenSource = null;