Я работаю над проектом, который использует MassTransit, но из-за длительной работы мне приходится использовать потребителей заданий, чтобы обойти тайм-аут в RabbitMQ.
Однако это приводит к Это проблема отмены этих незавершенных работ. Через веб-интерфейс RabbitMQ мы можем очищать очереди для сброса задержек в наших конвейерах, но это явно не работает с потребителями заданий.
Мой код учитывает CancellationToken, который передается с аргументом JobContext в IJobConsumer, но я не знаю, как его вызвать, и мне не удалось найти никакой документации о том, как это сделать.< /п>
Подробнее здесь: https://stackoverflow.com/questions/743 ... ogress-job
