NServiceBus TimeOut Manager

Question

NserviceBusを使用して、sagaでタイムアウト管理をテストするためのサンプルアプリケーションを開発していました。

サガは、タイムアウトは更新がnessageに来たならば私のコードは

以下のようなものです 5分にタイムアウトを更新起こる前に、それは1分 にタイムアウトだし始めたとき、私は、次の

を達成するためにトラインよ

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分間有効です。

ここで間違っていることを教えてください。事前に

おかげで、 Ajai

Answer 1

佐賀タイムアウトを更新することはできません。あなたが何をしても、彼らは火を放つでしょう。あなたのケースでは、両方のタイムアウトを受け取り、あなたのタイムアウトハンドラでコンプリートを呼び出すと、1分後にサガが終了します。これを考慮に入れるロジックを追加する必要があります。このような

何か、それを行う可能性があります：

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

は、この情報がお役に立てば幸い！