Fix inmemeory status update bug

src/DotNetCore.CAP.InMemoryStorage/IDataStorage.InMemory.cs

@@ -32,12 +32,14 @@ namespace DotNetCore.CAP.InMemoryStorage
         public Task ChangePublishStateAsync(MediumMessage message, StatusName state)
         {
             PublishedMessages[message.DbId].StatusName = state;
+            PublishedMessages[message.DbId].ExpiresAt = message.ExpiresAt;
             return Task.CompletedTask;
         }
 
         public Task ChangeReceiveStateAsync(MediumMessage message, StatusName state)
         {
             ReceivedMessages[message.DbId].StatusName = state;
+            ReceivedMessages[message.DbId].ExpiresAt = message.ExpiresAt;
             return Task.CompletedTask;
         }
 
@@ -106,7 +108,7 @@ namespace DotNetCore.CAP.InMemoryStorage
                 Retries = mdMessage.Retries,
                 Added = mdMessage.Added,
                 ExpiresAt = mdMessage.ExpiresAt,
-                StatusName = StatusName.Failed
+                StatusName = StatusName.Scheduled
             };
             return mdMessage;
         }

src/DotNetCore.CAP/Internal/IConsumerRegister.Default.cs

@@ -152,8 +152,7 @@ namespace DotNetCore.CAP.Internal
             client.OnMessageReceived += async (sender, transportMessage) =>
             {
                 _logger.MessageReceived(transportMessage.GetId(), transportMessage.GetName());
-
-                _cts.Token.ThrowIfCancellationRequested();
+               
                 long? tracingTimestamp = null;
                 try
                 {