NServiceBus 超时管理器

Question

我正在开发一个示例应用程序来使用 NserviceBus 测试 saga 中的超时管理。

我正在尝试实现以下目标

当传奇开始时将超时设置为 1 分钟 在超时发生之前，如果有更新，则将超时更新为 5 分钟 我的代码如下所示，

  public class OrderSaga : Saga<OrderSagaData>,
        IAmStartedByMessages<SampleMessage>,
        IHandleMessages<UpdateMessage>
    {
        public override void ConfigureHowToFindSaga()
        {
            ConfigureMapping<UpdateMessage>(s => s.PurchaseOrderNumber, m => m.Update);
        }

        public void Handle(SampleMessage message)
        {
            this.Data.PurchaseOrderNumber = message.Name;
            RequestTimeout(DateTime.Now.AddMinutes(1), message.Name);
        }


        private void Complete()
        {
            MarkAsComplete();
        }

        public override void Timeout(object state)
        {
            Complete();
        }


        #region IMessageHandler<UpdateMessage> Members

        public void Handle(UpdateMessage message)
        {
            this.Data.PurchaseOrderNumber = message.NewValue;     
            RequestTimeout(DateTime.Now.AddMinutes(5), message.Update);
        }

        #endregion
    }
}

但这里的问题是超时没有更新为 5 分钟。超时仍然有效 1 分钟。

你能让我知道这里出了什么问题吗？

提前致谢， 阿贾伊

Answer 1

Saga 超时无法更新。无论你做什么他们都会开火。在您的情况下，您将收到两个超时，并且考虑到您在超时处理程序中调用 Complete，您的传奇将在一分钟后结束。您需要添加一些考虑到这一点的逻辑。

像这样的事情可能会做到：

if(!updateReceived or state == ThisTimeoutWasRequestedByMyUpdateHandler)
   Complete();

希望这有帮助！