1

使用 NServiceBus 6 的回调功能，我发现无法提醒客户端请求处理程序失败。请求处理程序将经过所有可恢复性步骤，最终将消息放入错误队列。与此同时，客户只是坐在那里等待它的回复。

// Client code (e.g. in an MVC Controller)
var message = new FooRequest();
var response = await endpoint.Request<FooReponse>(message);

// Handler code
public class FooRequestHandler : IHandleMessages<FooRequest>
{
    Task Handle(FooRequest message, IMessageHandlerContext context)
    {
        throw new Exception("Fails before the reply");
        return context.Reply(new FooResponse());
    }
}

在上述情况下，如何让 MVC 控制器/调用代码知道处理程序已永久失败？

4

1 回答 1

5

这是设计使然。从客户端的角度来看，我建议您始终传递一个CancellationToken定义请求者可以等待多长时间来等待请求调用的回复。

var cancellationTokenSource = new CancellationTokenSource();
cancellationTokenSource.CancelAfter(TimeSpan.FromSeconds(5)); // your SLA timeout
var message = new Message();
try
{
    var response = await endpoint.Request<FooRequest>(message, cancellationTokenSource.Token)
                                 .ConfigureAwait(false);
}
catch (OperationCanceledException)
{
    // Exception that is raised when the CancellationTokenSource is canceled
}

客户端域定义允许客户端请求异步等待答案的时间。有关取消的更多信息，请参阅https://docs.particular.net/nservicebus/messaging/callbacks?version=callbacks_3#cancellation

于 2018-02-08T08:20:28.510 回答