Dans NServiceBus, comment puis-je gérer lorsqu'un message arrive sans saga correspondante?

Question

Si j'ai une saga composée de deux types de messages, disons démarrés par message1 et complétés par message2, puis-je retourner un rappel si un message2 arrive sans qu'un message1 existe déjà? Je sais qu'il va le vider dans la file d'erreurs, mais je veux être capable de retourner un état au client expéditeur pour dire qu'il y a un état d'erreur dû au fait que le premier message n'est pas là.

Answer 1

Alors je me suis dehors, je avais juste besoin de mettre en œuvre IFindSagas pour le type de message:

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; 
    } 
} 

Je ne sais pas si cela est le droit façon de le faire, mais ça marche!

Answer 2

Si vous avez une saga qui peut recevoir deux messages, mais les messages peuvent être reçus dans n'importe quel ordre, assurez-vous que la saga peut être démarrée par les deux messages. Ensuite, vérifiez si les deux messages sont arrivés en définissant un état dans la saga elle-même. Si les deux messages sont arrivés, marquez-le comme complet. Le comportement par défaut de NServicebBus est d'ignorer tout message qui n'a pas de saga correspondante. C'est parce que vous pouvez définir un délai d'expiration, par exemple. Si rien ne se passe dans les 24 heures, la saga peut envoyer un message Timeout à lui-même. Mais si quelque chose s'est passé et que vous avez marqué votre saga comme terminée, que devrait-il arriver au message Timeout? Par conséquent, NServiceBus l'ignore.