У нас вы можете посмотреть бесплатно The StartJobAttempt StartJobAttempt (Event) execution faulted или скачать в максимальном доступном качестве, которое было загружено на ютуб. Для скачивания выберите вариант из формы ниже:
Если кнопки скачивания не
загрузились
НАЖМИТЕ ЗДЕСЬ или обновите страницу
Если возникают проблемы со скачиванием, пожалуйста напишите в поддержку по адресу внизу
страницы.
Спасибо за использование сервиса ClipSaver.ru
Hello everyone! I hope this video has helped solve your questions and issues. This video is shared because a solution has been found for the question/problem. I create videos for questions that have solutions. If you have any other issues, feel free to reach out to me on Instagram: / ky.emrah Below, you can find the text related to the question/problem. In the video, the question will be presented first, followed by the answers. If the video moves too fast, feel free to pause and review the answers. If you need more detailed information, you can find the necessary sources and links at the bottom of this description. I hope this video has been helpful, and even if it doesn't directly solve your problem, it will guide you to the source of the solution. I'd appreciate it if you like the video and subscribe to my channel!The StartJobAttempt StartJobAttempt (Event) execution faulted I'm using MassTransit 8.25.0 on .NET 8. I have a Windows service with a scheduler and a job consumer. Can't figure out how to queue a job, IPublishEndpoint from example is a scoped service, so I can't inject it. IPublishEndpoint example My attempts clientFactory.CreateRequestClient clientFactory.CreateRequestClient clientFactory.CreateRequestClient public class ImportScheduler( IScheduleConfig ImportScheduler config, ILogger ImportScheduler logger, IClientFactory clientFactory) : CronJobService(config.CronExpression, config.TimeZoneInfo, logger) { protected override async Task DoWork(CancellationToken cancellationToken) { var requestClient = clientFactory.CreateRequestClient ImportRequested (); var jobId = NewId.Next(); await requestClient.GetResponse JobSubmissionAccepted (new ImportRequested( jobId.ToGuid(), Guid.Parse("7718D173-1F3F-4F8C-B282-5B5A1C183BCE")), cancellationToken); } } public class ImportScheduler( IScheduleConfig ImportScheduler config, ILogger ImportScheduler logger, IClientFactory clientFactory) : CronJobService(config.CronExpression, config.TimeZoneInfo, logger) { protected override async Task DoWork(CancellationToken cancellationToken) { var requestClient = clientFactory.CreateRequestClient ImportRequested (); var jobId = NewId.Next(); await requestClient.GetResponse JobSubmissionAccepted (new ImportRequested( jobId.ToGuid(), Guid.Parse("7718D173-1F3F-4F8C-B282-5B5A1C183BCE")), cancellationToken); } } This throws an error: MassTransit.EventExecutionException: The StartJobAttempt (Event) execution faulted MassTransit.PayloadNotFoundException: The payload was not found: MassTransit.MessageSchedulerContext MassTransit.EventExecutionException: The StartJobAttempt (Event) execution faulted MassTransit.PayloadNotFoundException: The payload was not found: MassTransit.MessageSchedulerContext Tried to create IPublishEndpoint from IBus with GetPublishSendEndpoint, got ISendEndpoint Tried to create IPublishEndpoint from IBus with GetPublishSendEndpoint, got ISendEndpoint IPublishEndpoint IBus GetPublishSendEndpoint ISendEndpoint public class ImportScheduler( IScheduleConfig ImportScheduler config, ILogger ImportScheduler logger, IBus bus) : CronJobService(config.CronExpression, config.TimeZoneInfo, logger) { protected override async Task DoWork(CancellationToken cancellationToken) { var publishEndpoint = await bus.GetPublishSendEndpoint SubmitJob ImportRequested (); var jobId = NewId.Next(); await publishEndpoint.Send(new { JobId = jobId, Job = new ImportRequested( jobId.ToGuid(), Guid.Parse("7718D173-1F3F-4F8C-B282-5B5A1C183BCE")) }, cancellationToken); } } public class ImportScheduler( IScheduleConfig ImportScheduler config, ILogger ImportScheduler logger, IBus bus) : CronJobService(config.CronExpression, config.TimeZoneInfo, logger) { protected override async Task DoWork(CancellationToken cancellationToken) { var publishEndpoint = await bus.GetPublishSendEndpoint SubmitJob ImportRequested (); var jobId = NewId.Next(); await publishEndpoint.Send(new { JobId = jobId, Job = new ImportRequesSource of the question: https://stackoverflow.com/questions/7... Question and source license information: https://meta.stackexchange.com/help/l... https://stackoverflow.com/