CQRS/EventStore: comment répartir les événements non-triés?

Question

Avec la bibliothèque étonnante EventStore 3.0 il y a un

store.Advanced.GetUnDispatchedCommits(); 

Quelle est la meilleure façon/modèle pour expédier ces? Est-ce que je fais simplement une boucle et appelle mon répartiteur, puis je mets à jour le commit pour indiquer qu'il a été distribué (si oui, comment le ferais-je?)?

De même, lors du câblage de l'EventStore, une répartition est tentée sur les validations non attribuées au démarrage. Comment puis-je éviter que cela soit fait?

Ces questions sont plus à voir avec l'apprentissage du fonctionnement d'EventStore que d'un problème avec un projet.

TIA

JD

Answer 1

Le "planificateur d'expédition" est la chose qui tente de charger tous les commits undispatched lors du démarrage. Vous pouvez créer le vôtre et remplacer la méthode appelée au démarrage. En même temps, je ne le recommanderais pas. Le modèle qui se cache derrière l'EventStore est entièrement basé sur la tolérance aux pannes et la reprise après défaillance. Plus précisément, si la machine meurt juste après la validation d'une validation et que le répartiteur n'a pas encore terminé d'envoyer le message sur le fil, vous voulez que l'EventStore reprenne là où il s'était arrêté au démarrage en envoyant les validations non réparties.