在 NServiceBus 中，当消息传入而没有匹配的传奇时，我该如何处理？

发布于 2024-12-03 01:02:42 字数 151 浏览 3 评论 0原文

如果我有一个由两种消息类型组成的传奇，比如由 message1 开始并由 message2 完成，那么如果 message2 进入而 message1 不存在，我可以返回回调吗？我知道它会将其转储到错误队列中，但我希望能够向发送客户端返回一个状态，表明由于第一条消息不存在而存在错误状态。

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

难如初 2024-12-10 01:02:42

所以我想通了，我只需要为消息类型实现 IFindSagas ：

public class MySagaFinder : IFindSagas<MySagaData>.Using<Message2>
{
    public ISagaPersister Persister { get; set; }
    public IBus Bus { get; set; }

    public MySagaFinder FindBy(Message2 message)
    {
        var data = Persister.Get<MySagaData>("MessageIdProperty", message.MessageIdProperty);
        if (data == null)
        {
            Bus.Return(0);
        }
        return data;
    }
}

我不知道这是否是正确的方法，但它有效！

So I figured it out, I just needed to implement IFindSagas for the message type:

public class MySagaFinder : IFindSagas<MySagaData>.Using<Message2>
{
    public ISagaPersister Persister { get; set; }
    public IBus Bus { get; set; }

    public MySagaFinder FindBy(Message2 message)
    {
        var data = Persister.Get<MySagaData>("MessageIdProperty", message.MessageIdProperty);
        if (data == null)
        {
            Bus.Return(0);
        }
        return data;
    }
}

I don't know if this is the right way to do it, but it works!

回复收藏 0 原文

岁月无声 2024-12-10 01:02:42

如果您的 saga 可以接收两条消息，但可以按任意顺序接收消息，请确保两条消息都可以启动 saga。然后通过在传奇本身中设置某种状态来验证两条消息是否已到达。如果两条消息均已到达，则将其标记为完成。

默认的 NServicebBus 行为是忽略任何没有相应传奇的消息。例如，这是因为您可以设置超时。如果 24 小时内没有任何反应，saga 可以向自身发送一条 Timeout 消息。但是，如果确实发生了某些事情并且您将传奇标记为已完成，那么超时消息会发生什么情况？因此 NServiceBus 会忽略它。

回复收藏 0 原文

~没有更多了~