如何解决MassTransit:取消长期运行的工作
如何取消基于IJobConsumer的长期运行的工作?
我尝试将CancelJob发布到公共汽车,但是没有结果。
[HttpGet]
public async Task < IActionResult > Get() {
var response = await _client.GetResponse < JobSubmissionAccepted > (new {
Id = "test"
});
await Task.Delay(TimeSpan.FromSeconds(3));
await _endpoint.Publish < CancelJob > (new {
JobId = response.Message.JobId,Reason = "I give up"
});
return Ok(response.Message.JobId);
}
解决方法
取消工作消费方后,会发出CancellationToken
的{{1}}属性的信号。令牌发出信号后,应由工作使用者的JobContext
方法正确取消。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。