Masstransit的Mediator：如何取消长期执行的消费者执行？

问题描述

我已经建立了一个Masstransit的Mediator实例，并且得到了如下响应：

try
{
    var client = mediator.CreateRequestClient<GetorderStatus>();
    var response = await client.GetResponse<OrderStatus>(command,cancellationToken);
    // ...
}
catch (Exception ex)
{    
    Log(ex);
}

我的消费者是这样的：

public async Task Consume(ConsumeContext<GetorderStatus> context)
{
    try
    {
        await Task.Delay(Timeout.Infinite,context.CancellationToken); // long-running task emulation

        // ...

        await context.RespondAsync<OrderStatus>(...)
    }
    catch (Exception ex)
    {
        Log(ex);
    }    
}

在生产者部分，如果调用了cancellationTokenSource.Cancel()（通过按下UI中的“取消”按钮），则消费者永远不会取消，因此它将继续在Task.Delay中等待并且永远不会抛出。

消费者不应该取消操作吗？
如果这是预期的行为，如何从生产者方取消消费者执行？凭直觉，我以为可以通过取消标记来做到这一点，但似乎我错过了一些事情。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

masstransit