当从Masstransit 7. 3升级到Masstransit 8. 0. 15时，我发现了一个似乎是突破性的变化，我想知道以前是否还有人遇到过这个问题。
我有一个 Saga 计划每30秒重新启动一次作业：

Schedule(() => RestartConversion, instance => instance.RestartConversionTokenId, s =>
{
    s.Delay = TimeSpan.FromSeconds(30);
    s.Received = r => r.CorrelateById(context => context.Message.ItemId);
});

然而，在我的单元测试中，在以前的7.3版中，我能够通过发布RestartConversionEvent手动触发此事件，这将在When(RestartConversion.Received)中触发。

var endPoint = await Harness.Bus.GetSendEndpoint(Harness.InputQueueAddress);
await endPoint.Send(new DocumentConversionSaga.RestartConversionSchedule
{
    ItemId = Guid.Parse(uploadDocumentInfo.ItemId),
    ConversionJobInstanceId = conversionInstanceId,
    PreviewJobInstanceId = previewInstanceId
});

这种行为在Masstransit 8中似乎不再起作用，因为如果我等待30秒，我可以看到RestartConversion事件被自动发送。是否有解决此问题的方法？
线束配置：

.AddMassTransitInMemoryTestHarness(cfg =>
{
    cfg.SetInMemorySagaRepositoryProvider();
    cfg.AddSagaStateMachine<DocumentConversionSaga, DocumentConversionState>().InMemoryRepository();
    cfg.AddRequestClient<StartConversionCommand>();
})

Harness = provider.GetRequiredService<InMemoryTestHarness>();
Harness.OnConfigureBus += cfg =>
{
    cfg.UseDelayedMessageScheduler();
    BusTestFixture.ConfigureBusDiagnostics(cfg);
    cfg.UseMessageData(new InMemoryMessageDataRepository());
    cfg.UseNewtonsoftJsonSerializer();
};

我尝试更改内存中的测试工具以使用以下内容，但结果完全相同。

.AddMassTransitTestHarness(cfg =>
{
    cfg.SetInMemorySagaRepositoryProvider();
    cfg.AddSagaStateMachine<DocumentConversionSaga, DocumentConversionState>().InMemoryRepository();
    cfg.AddRequestClient<StartConversionCommand>();
    cfg.UsingInMemory((ctx, x) =>
    {
        x.UseDelayedMessageScheduler();
        BusTestFixture.ConfigureBusDiagnostics(x);
        x.UseMessageData(new InMemoryMessageDataRepository());
        x.UseNewtonsoftJsonSerializer();
        x.ConfigureEndpoints(ctx);
    });
})