Борьба за реализацию IFindSagas

Question

У меня есть сага, которая работает в течение дня.

Получив сообщение, я хочу найти активную сагу и сделать что-то в методе Handle (message).

У меня нет метода ConfigureHowToFindSagas, поскольку я хочу текущий, если он есть. Все полученные сообщения будут влиять на одну сагу до тех пор, пока сообщение таймаута не будет получено. Текущая сага завершается, и после получения нового сообщения создается новая. Но из того, что я прочитал, мне нужно реализовать IFindSagas, чтобы это сделать, и, возможно, мой собственный сага.

Мне нужен совет о том, с чего начать, а также если это правильный путь. Примеры кода были бы полезны, поскольку я по-прежнему относительно новичок в использовании интерфейсов.

// fragment from Saga<PaymentSagaBase> 
public void Run() 
     { 

     ScheduleBatchIDForSession = Guid.NewGuid(); 

     // Message handlers aren't auto-subscribed in Saga scenarios so it needs to happen here. 
     Bus.Subscribe<PaymentRequested>(); 
     Bus.Subscribe<PaymentCancelled>(); 

     Logger.Info(string.Format("Creating new Saga."); 

     RequestUtcTimeout(DateTime.Now.AddHours(23), "End of batch"); 
    } 

Answer 1

Я думаю, что я просто answered a similar question на днях. Если у вас есть более сложная логика, чтобы найти существующую сагу, тогда реализуйте интерфейс IFindSagas, в противном случае переопределение метода ConfigureHowToFindSaga должно быть достаточно. Все, что вам нужно сделать, это убедиться, что конфигурация соответствует сообщению, которое запустило сагу. Вроде как это:

public class MySaga : Saga<MySagaData>, IAmStartedByMessages<Message1> 
{ 
    public override void ConfigureHowToFindSaga() 
    { 
     ConfigureMapping<Message1>(s => s.SomeID, m => m.SomeID); 
    } 

    public void Handle(Message1 message) 
    { 
     if(Data.Id != Guid.Empty) 
     { 
      // handle existing saga 
     } 
     else // create new saga instance 
     { 
      this.Data.SomeID = message.SomeID; 
      RequestUtcTimeout(DateTime.Now.AddHours(23), "End of batch"); 
     } 

     // rest of the code to handle Message1 
    } 

    public override void Timeout(object state) 
    { 
     // some business action 
    } 
} 

НТН