Как выполнить интеграционное тестирование с Quartz в Xunit ⇐ C#

[Anonymous]

Мне нужно протестировать Quartz Job. Роль задания quarts — запустить событие домена, которое изменяет баланс пользователя. Вручную все работает нормально.
Проблема в тесте заключается в том, что Job вообще не обрабатывает исходящие сообщения.
ProcessedOnUtc остается нулевым.
Тест:
[Fact]
public async Task Should_WinAuction_When_BuyoutPrice()
{
var user = User.Create(Guid.NewGuid(), "example", "example@.com");
var userTwo = User.Create(Guid.NewGuid(), "example2", "example2@.com");
var oldBalance = user.Balance;
_userRepository.Add(user);
_userRepository.Add(userTwo);
await UnitOfWork.SaveChangesAsync();
var auction = Auction.Create(Guid.NewGuid(), "example", "description", 10m, 11m, DateTime.Now, user.Id);
_auctionRepository.Add(auction);
await UnitOfWork.SaveChangesAsync();
var command = new PlaceBidCommand(11m, userTwo.Id, auction.Id);
var result = await Sender.Send(command);
Assert.True(result.IsSuccess);
var bid = await _bidRepository.GetByIdAsync(result.Data.BidId);
Assert.NotNull(bid);
Assert.Equal(userTwo.Id, auction.WinnerId);
await Task.Delay(5000);
var updatedUser = DbContext.Users.FirstOrDefault(u => u.Id == userTwo.Id);

Assert.True(updatedUser.Balance != 10000);
}

Кварцевая регистрация:
Quartz:
services.AddQuartz(options =>
{
var jobKey = JobKey.Create(nameof(ProcessOutboxMessages));
options.SchedulerId = Guid.NewGuid().ToString();
options.SchedulerName = "OutboxMessages";
options.AddJob
(jobKey)
.AddTrigger(trigger => trigger.ForJob(jobKey).WithSimpleSchedule(schedule =>
{
schedule.WithIntervalInSeconds(1);
schedule.RepeatForever();
}));
});
services.AddQuartzHostedService(options =>
{
options.WaitForJobsToComplete = true;
});

Работа
public async Task Execute(IJobExecutionContext context)
{
var messages = await _dbContext.OutboxMessages
.Where(x => x.ProcessedOnUtc == null)
.Take(20)
.ToListAsync();
foreach (var message in messages)
{
IDomainEvent? domainEvent = JsonConvert.DeserializeObject(message.Content, new JsonSerializerSettings() { TypeNameHandling = TypeNameHandling.All });
if (domainEvent == null)
{
continue;
}
await _publisher.Publish(domainEvent);
message.ProcessedOnUtc = DateTime.UtcNow;
}

await _dbContext.SaveChangesAsync();
}


Подробнее здесь: https://stackoverflow.com/questions/785 ... z-in-xunit